com.j_spaces.jms
Class GSTemporaryTopicImpl
java.lang.Object
com.j_spaces.jms.GSTopicImpl
com.j_spaces.jms.GSTemporaryTopicImpl
- All Implemented Interfaces:
- Serializable, Remote, Destination, TemporaryTopic, Topic
public class GSTemporaryTopicImpl
- extends GSTopicImpl
- implements TemporaryTopic, Serializable
GigaSpaces implementation of the javax.jms.TemporaryTopic
interface.
This class represents a queue which provides it's messages exclusively to one
consumer at a time.
In our case, the Topic name represents the GigaSpaces entry name.
We use the same space proxy we obtained in the session and we write another External
Entry, which will have a class name of 'TempTopic'.
The only message consumers that can consume from a temporary destination
are those created by the same connection that created the destination. Any
message producer can send to the temporary destination. If you close the connection
that a temporary destination belongs to, the destination is closed and its contents
lost.
You can use temporary destinations to implement a simple request/reply
mechanism. If you create a temporary destination and specify it as the value of the
JMSReplyTo message header field when you send a message, the consumer of the
message can use the value of the JMSReplyTo field as the destination to which it
sends a reply and can also reference the original request by setting the
JMSCorrelationID header field of the reply message to the value of the
JMSMessageID header field of the request.
- See Also:
- Serialized Form
GSTemporaryTopicImpl
public GSTemporaryTopicImpl(String topicName,
String srcID)
- Parameters:
topicName
- srcID
-
delete
public void delete()
throws JMSException
- We clear this temp external entry from space.
- Specified by:
delete
in interface TemporaryTopic
- Throws:
JMSException
- See Also:
TemporaryTopic.delete()
getSourceID
public String getSourceID()
- returns the source id of the object which have created
this temp destination at first place.
It might be a specific MessageProducer or MessageConsumere etc.
- Returns:
- sourceID
setSourceID
public void setSourceID(String string)
- Parameters:
string
-
getDescription
public String getDescription()