|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.exolab.jms.server.mipc.IpcJmsSessionSender
public class IpcJmsSessionSender
This class contains the ipc connection to a receiver or subscriber for passing the JmsMessages. If the connection is detected as closed, the Session will also be shutdown.
IpcJmsSessionConnection
,
JmsServerSession
,
Client
Constructor Summary | |
---|---|
IpcJmsSessionSender(org.exolab.core.mipc.ObjectChannel client,
JmsServerSession session)
Create a connection to the client listener for sending JmsMessages. |
Method Summary | |
---|---|
void |
close()
Remove the callback from the JmsServerSession. |
void |
onMessage(javax.jms.Message message)
Send a JmsMessage to a listener. |
void |
onMessageAvailable(long clientId)
Notify the specified client that a message avaiable. |
void |
onMessages(java.util.Vector messages)
Send the collection of messages to the client. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public IpcJmsSessionSender(org.exolab.core.mipc.ObjectChannel client, JmsServerSession session)
client
- The connection to the client.session
- The session this connection belongs to.Method Detail |
---|
public void onMessage(javax.jms.Message message)
onMessage
in interface javax.jms.MessageListener
message
- The message to send.public void onMessages(java.util.Vector messages)
onMessages
in interface JmsMessageListener
messages
- - collection of MessageImpl objectspublic void onMessageAvailable(long clientId)
onMessageAvailable
in interface JmsMessageListener
clinet
- - the client identitypublic void close()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |