org.hornetq.core.protocol.core.impl

Class CoreSessionCallback

java.lang.Object

org.hornetq.core.protocol.core.impl.CoreSessionCallback

All Implemented Interfaces:

SessionCallback

public final class CoreSessionCallback
extends Object
implements SessionCallback

A CoreSessionCallback

Author:

Tim Fox

Constructor Summary

Constructors

Constructor and Description
CoreSessionCallback(String name, ProtocolManager protocolManager, Channel channel)

Method Summary

Modifier and Type	Method and Description
void	addReadyListener(ReadyListener listener)
void	closed()
void	disconnect(long consumerId, String queueName)
void	removeReadyListener(ReadyListener listener)
int	sendLargeMessage(ServerMessage message, long consumerID, long bodySize, int deliveryCount)
int	sendLargeMessageContinuation(long consumerID, byte[] body, boolean continues, boolean requiresResponse)
int	sendMessage(ServerMessage message, long consumerID, int deliveryCount)
void	sendProducerCreditsFailMessage(int credits, SimpleString address)
void	sendProducerCreditsMessage(int credits, SimpleString address)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CoreSessionCallback

public CoreSessionCallback(String name,
                           ProtocolManager protocolManager,
                           Channel channel)

Method Detail

sendLargeMessage

public int sendLargeMessage(ServerMessage message,
                            long consumerID,
                            long bodySize,
                            int deliveryCount)

Specified by:

sendLargeMessage in interface SessionCallback

sendLargeMessageContinuation

public int sendLargeMessageContinuation(long consumerID,
                                        byte[] body,
                                        boolean continues,
                                        boolean requiresResponse)

Specified by:

sendLargeMessageContinuation in interface SessionCallback

sendMessage

public int sendMessage(ServerMessage message,
                       long consumerID,
                       int deliveryCount)

Specified by:

sendMessage in interface SessionCallback

sendProducerCreditsMessage

public void sendProducerCreditsMessage(int credits,
                                       SimpleString address)

Specified by:

sendProducerCreditsMessage in interface SessionCallback

sendProducerCreditsFailMessage

public void sendProducerCreditsFailMessage(int credits,
                                           SimpleString address)

Specified by:

sendProducerCreditsFailMessage in interface SessionCallback

closed

public void closed()

Specified by:

closed in interface SessionCallback

addReadyListener

public void addReadyListener(ReadyListener listener)

Specified by:

addReadyListener in interface SessionCallback

removeReadyListener

public void removeReadyListener(ReadyListener listener)

Specified by:

removeReadyListener in interface SessionCallback

disconnect

public void disconnect(long consumerId,
                       String queueName)

Specified by:

disconnect in interface SessionCallback