jrun.jms.core.server.mipc
Class IpcJmsSessionSender

java.lang.Object
  |
  +--jrun.jms.core.server.mipc.IpcJmsSessionSender

All Implemented Interfaces:

JmsMessageListener

public class IpcJmsSessionSender

extends java.lang.Object

implements JmsMessageListener

This class conatins 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.

Version:

$Revision: 1.4 $ $Date: 2001/05/29 06:46:26 $

Author:

Jim Mourikis

See Also:

org.exolab.jms.server.mipc.IpcJmsSessionConnection, org.exolab.jms.server.JmsServerSession, org.exolab.core.ipc.Client

Constructor Summary

IpcJmsSessionSender(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	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

IpcJmsSessionSender

public IpcJmsSessionSender(ObjectChannel client,
                           JmsServerSession session)

Create a connection to the client listener for sending JmsMessages.

Parameters:

client - The connection to the client.

session - The session this connection belongs to.

Method Detail

onMessage

public void onMessage(javax.jms.Message message)

Send a JmsMessage to a listener.

Parameters:

message - The message to send.

onMessages

public void onMessages(java.util.Vector messages)

Send the collection of messages to the client. This is used for async message delivery.

Specified by:

onMessages in interface JmsMessageListener

Parameters:

messages - - collection of MessageImpl objects

close

public void close()

Remove the callback from the JmsServerSession.