oracle.integration.platform.blocks.event.jms2

Class EdnJmsEventReader

java.lang.Object

oracle.integration.platform.blocks.event.jms2.EdnJmsEventReader

public class EdnJmsEventReader
extends Object

Method Summary

Modifier and Type	Method and Description
void	close() clean up the state and close the TopicConnection of the reader instance;
static EdnJmsEventReader	createReader(javax.jms.TopicConnection topicConn, javax.jms.Topic topic, String subName, String clientId, QName eventName, XPathFilter filter, JmsConfig.JmsType jmsType, long timeout, boolean isXA, UserTransaction userTx, oracle.soa.management.facade.edn.IEDN edn)
BusinessEvent	read() consume an EDN event from topic and return event to the caller
BusinessEvent	read(long t) consume an EDN event from topic and return event to the caller
void	start() start message delivery from the topic, called by caller to control the event consuming;
void	stop() temp stop the message delivery from the topic, called by caller to control the event consuming;

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createReader

public static EdnJmsEventReader createReader(javax.jms.TopicConnection topicConn,
                                             javax.jms.Topic topic,
                                             String subName,
                                             String clientId,
                                             QName eventName,
                                             XPathFilter filter,
                                             JmsConfig.JmsType jmsType,
                                             long timeout,
                                             boolean isXA,
                                             UserTransaction userTx,
                                             oracle.soa.management.facade.edn.IEDN edn)
                                      throws javax.jms.JMSException

Throws:

javax.jms.JMSException

start

public void start()
           throws Exception

start message delivery from the topic, called by caller to control the event consuming;

Throws:

javax.jms.JMSException

Exception

stop

public void stop()
          throws Exception

temp stop the message delivery from the topic, called by caller to control the event consuming;

Throws:

javax.jms.JMSException

Exception

close

public void close()
           throws Exception

clean up the state and close the TopicConnection of the reader instance;

Throws:

javax.jms.JMSException

Exception

read

public BusinessEvent read()

consume an EDN event from topic and return event to the caller

Returns:

- the edn event;

read

public BusinessEvent read(long t)

consume an EDN event from topic and return event to the caller

Parameters:

t - - time out for receive message from subscription;

Returns: