org.hornetq.core.protocol.proton

Class ProtonConsumer

java.lang.Object

org.hornetq.core.protocol.proton.ProtonConsumer

All Implemented Interfaces:

ProtonDeliveryHandler

public class ProtonConsumer
extends Object
implements ProtonDeliveryHandler

A this is a wrapper around a HornetQ ServerConsumer for handling outgoing messages and incoming acks via a Proton Sender

Author:

Andy Taylor

Constructor Summary

Constructors

Constructor and Description
ProtonConsumer(ProtonRemotingConnection connection, org.apache.qpid.proton.engine.Sender sender, ProtonSession protonSession, HornetQServer server, ProtonProtocolManager protonProtocolManager)

Method Summary

Methods

Modifier and Type	Method and Description
void	checkState()
void	close()
long	getConsumerID()
int	handleDelivery(ServerMessage message, int deliveryCount)
void	init()
void	onMessage(org.apache.qpid.proton.engine.Delivery delivery)
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

ProtonConsumer

public ProtonConsumer(ProtonRemotingConnection connection,
              org.apache.qpid.proton.engine.Sender sender,
              ProtonSession protonSession,
              HornetQServer server,
              ProtonProtocolManager protonProtocolManager)

Method Detail

start

public void start()
           throws HornetQAMQPException

Throws:

HornetQAMQPException

init

public void init()
          throws HornetQAMQPException

Throws:

HornetQAMQPException

close

public void close()
           throws HornetQAMQPException

Specified by:

close in interface ProtonDeliveryHandler

Throws:

HornetQAMQPException

getConsumerID

public long getConsumerID()

handleDelivery

public int handleDelivery(ServerMessage message,
                 int deliveryCount)

onMessage

public void onMessage(org.apache.qpid.proton.engine.Delivery delivery)
               throws HornetQAMQPException

Specified by:

onMessage in interface ProtonDeliveryHandler

Throws:

HornetQAMQPException

checkState

public void checkState()

Specified by:

checkState in interface ProtonDeliveryHandler