TIBCO EMS .NET API 8.5
TIBCO EMS .NET API 8.5
|
A TopicSession object provides methods for creating TopicPublisher, TopicSubscriber. More...
Public Member Functions | |
TopicSubscriber | CreateSubscriber (Topic topic) |
Create a nondurable subscriber to the specified topic. More... | |
TopicSubscriber | CreateSubscriber (Topic topic, string messageSelector, bool noLocal) |
Create a nondurable subscriber to the specified topic, using a message selector or specifying whether messages published by its own connection should be delivered to it. More... | |
TopicPublisher | CreatePublisher (Topic topic) |
Create a publisher for the specified topic. More... | |
![]() | |
QueueBrowser | CreateBrowser (Queue queue) |
Create a QueueBrowser object to peek at the messages on the specified queue. More... | |
QueueBrowser | CreateBrowser (Queue queue, string messageSelector) |
Create a QueueBrowser object to peek at the messages on the specified queue using a message selector. More... | |
MessageConsumer | CreateConsumer (Destination dest) |
Create a MessageConsumer for a specific destination. More... | |
MessageConsumer | CreateConsumer (Destination dest, string messageSelector) |
Create a MessageConsumer for a specific destination, using a message selector. More... | |
MessageConsumer | CreateConsumer (Destination dest, string messageSelector, bool noLocal) |
Create MessageConsumer for the specified destination, using a message selector. This method can specify whether messages published by its own connection should be delivered to it, if the destination is a topic More... | |
MessageConsumer | CreateSharedConsumer (Topic topic, string sharedSubscriptionName) |
Create a shared non-durable subscription (with the specified name on the specified topic - if one does not already exist), and a consumer on that subscription. More... | |
MessageConsumer | CreateSharedConsumer (Topic topic, string sharedSubscriptionName, string messageSelector) |
Create a shared non-durable subscription (with the specified name on the specified topic - if one does not already exist), and a consumer on that subscription, using the specified message selector. More... | |
MessageConsumer | CreateSharedDurableConsumer (Topic topic, string name) |
Create a shared durable subscription (with the specified name on the specified topic - if one does not already exist), and a consumer on that subscription. More... | |
MessageConsumer | CreateSharedDurableConsumer (Topic topic, string name, string messageSelector) |
Create a shared durable subscription (with the specified name on the specified topic - if one does not already exist), and a consumer on that subscription, using the specified message selector. More... | |
TemporaryTopic | CreateTemporaryTopic () |
Create a TemporaryTopic object More... | |
TemporaryQueue | CreateTemporaryQueue () |
Create a TemporaryQueue object More... | |
TopicSubscriber | CreateDurableSubscriber (Topic topic, string name) |
Create a durable subscriber to the specified topic More... | |
TopicSubscriber | CreateDurableSubscriber (Topic topic, string name, string messageSelector, bool noLocal) |
Create a durable subscriber to the specified topic, using a message selector and specifying whether messages published by its own connection should be delivered to it. More... | |
Topic | CreateTopic (string topicName) |
Create a topic More... | |
Queue | CreateQueue (string queueName) |
Create a queue More... | |
MessageProducer | CreateProducer (Destination dest) |
Create a MessageProducer to send messages to the specified destination. More... | |
void | Unsubscribe (string name) |
Unsubscribe a durable topic subscription More... | |
BytesMessage | CreateBytesMessage () |
Create a byte array message More... | |
MapMessage | CreateMapMessage () |
Create a MapMessage object. A MapMessage object is used to send a self-defining set of name-value pairs, where names are String objects and values are primitive values in the .NET programming language. More... | |
Message | CreateMessage () |
Create a Message object. The Message interface is the root interface of all TIBCO EMS messages. A Message object holds all the standard message header information. It can be sent when a message containing only header information is sufficient More... | |
ObjectMessage | CreateObjectMessage () |
Create an ObjectMessage object. An ObjectMessage object is used to send a message that contains a serializable .NET object. More... | |
ObjectMessage | CreateObjectMessage (object obj) |
Create an ObjectMessage object. An ObjectMessage object is used to send a message that contains a serializable .NET object. More... | |
StreamMessage | CreateStreamMessage () |
Create a StreamMessage object More... | |
TextMessage | CreateTextMessage () |
Create a TextMessage object More... | |
TextMessage | CreateTextMessage (string text) |
Create a TextMessage object More... | |
virtual void | Commit () |
Commit the open transaction More... | |
virtual void | Rollback () |
Roll back messages in the current transaction More... | |
void | Recover () |
Recover from undetermined state during message processing More... | |
void | Close () |
Close a session and reclaim resources More... | |
void | Run () |
Obsolete: Not to be used by ordinary JMS Clients More... | |
override string | ToString () |
Returns a string representation of this Session object. More... | |
Additional Inherited Members | |
![]() | |
const int | SESSION_TRANSACTED = TIBCO.EMS.Session.SESSION_TRANSACTED |
The session is transacted More... | |
const int | AUTO_ACKNOWLEDGE = TIBCO.EMS.Session.AUTO_ACKNOWLEDGE |
Automatic acknowledgment More... | |
const int | CLIENT_ACKNOWLEDGE = TIBCO.EMS.Session.CLIENT_ACKNOWLEDGE |
Client acknowledgment More... | |
const int | DUPS_OK_ACKNOWLEDGE = TIBCO.EMS.Session.DUPS_OK_ACKNOWLEDGE |
Duplication ok acknowledgment More... | |
const int | NO_ACKNOWLEDGE = TIBCO.EMS.Session.NO_ACKNOWLEDGE |
No acknowledge acknowledge mode More... | |
const int | EXPLICIT_CLIENT_ACKNOWLEDGE = TIBCO.EMS.Session.EXPLICIT_CLIENT_ACKNOWLEDGE |
Explicit client acknowledge mode More... | |
const int | EXPLICIT_CLIENT_DUPS_OK_ACKNOWLEDGE = TIBCO.EMS.Session.EXPLICIT_CLIENT_DUPS_OK_ACKNOWLEDGE |
Explicit client acknowledge mode with dups_ok More... | |
![]() | |
int | AcknowledgeMode [get] |
Get the acknowledge mode of the session as integer constants as defined in Session class. More... | |
Connection | Connection [get] |
Get the connection the session belongs to More... | |
bool | IsClosed [get] |
bool | IsTransacted [get] |
Get whether the session is transacted More... | |
TIBCO.EMS.SessionMode | SessionAcknowledgeMode [get] |
Get the acknowledge mode of the session as a SessionMode type More... | |
IMessageListener | MessageListener [get, set] |
Get or set the message listener for the session. -Deprecated, use MessageConsumer.MessageListener instead. More... | |
bool | Transacted [get] |
Get whether an open session is transacted More... | |
A TopicSession object provides methods for creating TopicPublisher, TopicSubscriber.
Note: The TopicSession class is for backwards compatibility to support older clients. New clients should use the Session class.
A TopicSession is used for creating Pub/Sub specific objects. In general, use the Session object, and use TopicSession only to support existing code. Using the Session object simplifies the programming model and allows transactions to be used across the two messaging domains
|
inline |
Create a publisher for the specified topic.
A client uses a TopicPublisher object to publish messages on a topic. Each time a client creates a TopicPublisher on a topic, it defines a new sequence of messages that have no ordering relationship with the messages it has previously sent.
The TopicPublisher object will be recreated during connection recovery process.
topic | the Topic to publish to, or null if this is an unidentified producer |
|
inline |
Create a nondurable subscriber to the specified topic.
A client uses a TopicSubscriber object to receive messages that have been published to a topic.
Regular TopicSubscriber objects are not durable. They receive only messages that are published while they are active.
In some cases, a connection may both publish and subscribe to a topic. The subscriber NoLocal attribute allows a subscriber to inhibit the delivery of messages published by its own connection. The default value for this attribute is false
The TopicSubscriber object will be recreated during connection recovery process.
topic | The Topic to subscribe to |
TIBCO.EMS.InvalidDestinationException | if an invalid topic is specified |
|
inline |
Create a nondurable subscriber to the specified topic, using a message selector or specifying whether messages published by its own connection should be delivered to it.
A client uses a TopicSubscriber object to receive messages that have been published to a topic.
Regular TopicSubscriber objects are not durable. They receive only messages that are published while they are active. Messages filtered out by a subscriber's message selector will never be delivered to the subscriber. From the subscriber's perspective, they do not exist.
In some cases, a connection may both publish and subscribe to a topic. The subscriber NoLocal attribute allows a subscriber to inhibit the delivery of messages published by its own connection. The default value for this attribute is false.
The TopicSubscriber object will be recreated during connection recovery process.
topic | the Topic to subscribe to |
messageSelector | 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. |
noLocal | if set, inhibits the delivery of messages published by its own connection |