|
Oracle® Streams Advanced Queuing Java API Reference Release 1 (10.1) B12023-01 | |||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
A TopicConnection object is an active connection to a publish/subscribe JMS provider. A client uses a TopicConnection object to create one or more TopicSession objects for producing and consuming messages.
A TopicConnection can be used to create a TopicSession, from which specialized topic-related objects can be created. A more general, and recommended approach is to use the Connection object.
The TopicConnection object should be used to support existing code.
Connection, ConnectionFactory, TopicConnectionFactory| Method Summary | |
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Topic topic, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages)Creates a connection consumer for this connection (optional operation). |
javax.jms.ConnectionConsumer |
createDurableConnectionConsumer(javax.jms.Topic topic, java.lang.String subscriptionName, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages)Create a durable connection consumer for this connection (optional operation). |
javax.jms.TopicSession |
createTopicSession(boolean transacted, int acknowledgeMode)Creates a TopicSession object. |
| Methods inherited from interface javax.jms.Connection |
close, createConnectionConsumer, createSession, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop |
| Method Detail |
public javax.jms.TopicSession createTopicSession(boolean transacted,
int acknowledgeMode)
throws JMSException
TopicSession object.transacted - indicates whether the session is transactedacknowledgeMode - indicates whether the consumer or the client will acknowledge any messages it receives; ignored if the session is transacted. Legal values are Session.AUTO_ACKNOWLEDGE, Session.CLIENT_ACKNOWLEDGE, and Session.DUPS_OK_ACKNOWLEDGE.JMSException - if the TopicConnection object fails to create a session due to some internal error or lack of support for the specific transaction and acknowledgement mode.Session.AUTO_ACKNOWLEDGE, Session.CLIENT_ACKNOWLEDGE, Session.DUPS_OK_ACKNOWLEDGE
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Topic topic,
java.lang.String messageSelector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages)
throws JMSException
topic - the topic to accessmessageSelector - only messages with properties matching the message selector expression are delivered. A value of null or an empty string indicates that there is no message selector for the message consumer.sessionPool - the server session pool to associate with this connection consumermaxMessages - the maximum number of messages that can be assigned to a server session at one timeJMSException - if the TopicConnection object fails to create a connection consumer due to some internal error or invalid arguments for sessionPool and messageSelector.InvalidDestinationException - if an invalid topic is specified.InvalidSelectorException - if the message selector is invalid.ConnectionConsumer
public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic,
java.lang.String subscriptionName,
java.lang.String messageSelector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages)
throws JMSException
createDurableConnectionConsumer in interface Connectiontopic - the topic to accesssubscriptionName - durable subscription namemessageSelector - only messages with properties matching the message selector expression are delivered. A value of null or an empty string indicates that there is no message selector for the message consumer.sessionPool - the server session pool to associate with this durable connection consumermaxMessages - the maximum number of messages that can be assigned to a server session at one timeJMSException - if the TopicConnection object fails to create a connection consumer due to some internal error or invalid arguments for sessionPool and messageSelector.InvalidDestinationException - if an invalid topic is specified.InvalidSelectorException - if the message selector is invalid.ConnectionConsumer
|
Oracle® Streams Advanced Queuing Java API Reference Release 1 (10.1) B12023-01 | |||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||