public class TibjmsUFOTopicConnection extends TibjmsUFOConnection implements TopicConnection
Modifier and Type | Method and Description |
---|---|
ConnectionConsumer |
createConnectionConsumer(Topic topic,
java.lang.String messageSelector,
ServerSessionPool sessionPool,
int maxMessages)
Creates a connection consumer for this connection (optional operation).
|
ConnectionConsumer |
createDurableConnectionConsumer(Topic topic,
java.lang.String subscriptionName,
java.lang.String messageSelector,
ServerSessionPool sessionPool,
int maxMessages)
Creates a connection consumer for this connection (optional operation)
on the specific topic using an unshared durable subscription with
the specified name.
|
TopicSession |
createTopicSession(boolean transacted,
int acknowledgeMode)
Creates a
TopicSession object. |
close, createConnectionConsumer, createSession, createSession, createSession, createSharedConnectionConsumer, createSharedDurableConnectionConsumer, getClientID, getExceptionListener, getMetaData, recoverConnection, setClientID, setExceptionListener, start, stop, toString
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
close, createConnectionConsumer, createSession, createSession, createSession, createSharedConnectionConsumer, createSharedDurableConnectionConsumer, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop
public TopicSession createTopicSession(boolean transacted, int acknowledgeMode) throws JMSException
TopicConnection
TopicSession
object.createTopicSession
in interface TopicConnection
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 ConnectionConsumer createConnectionConsumer(Topic topic, java.lang.String messageSelector, ServerSessionPool sessionPool, int maxMessages) throws JMSException
TopicConnection
createConnectionConsumer
in interface TopicConnection
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 ConnectionConsumer createDurableConnectionConsumer(Topic topic, java.lang.String subscriptionName, java.lang.String messageSelector, ServerSessionPool sessionPool, int maxMessages) throws JMSException
Connection
This is an expert facility not used by ordinary JMS clients.
This method must not be used in a Java EE web or EJB application. Doing
so may cause a JMSException
to be thrown though this is not
guaranteed.
createDurableConnectionConsumer
in interface Connection
createDurableConnectionConsumer
in interface TopicConnection
createDurableConnectionConsumer
in class TibjmsUFOConnection
topic
- topic to accesssubscriptionName
- the name used to identify the unshared durable subscriptionmessageSelector
- 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 timeIllegalStateException
- if called on a QueueConnection
InvalidDestinationException
- if an invalid destination is specified.InvalidSelectorException
- if the message selector is invalid.JMSException
- if the Connection
object fails to create a
connection consumer for one of the following reasons:
sessionPool
and messageSelector
or
ConnectionConsumer
Copyright © TIBCO Software Inc. All rights reserved