org.exolab.jms.server.mipc
Class IpcJmsSessionSender

java.lang.Object
  |
  +--org.exolab.jms.server.mipc.IpcJmsSessionSender

All Implemented Interfaces:

JmsMessageListener, javax.jms.MessageListener

public class IpcJmsSessionSender

extends java.lang.Object

implements JmsMessageListener

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.

Version:

$Revision: 1.10 $ $Date: 2003/08/07 13:33:09 $

Author:

Jim Mourikis

See Also:

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

IpcJmsSessionSender

public IpcJmsSessionSender(org.exolab.core.mipc.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.

Specified by:

onMessage in interface javax.jms.MessageListener

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

onMessageAvailable

public void onMessageAvailable(long clientId)

Notify the specified client that a message avaiable.

Specified by:

onMessageAvailable in interface JmsMessageListener

Parameters:

clinet - - the client identity

close

public void close()

Remove the callback from the JmsServerSession.