org.hornetq.core.protocol.proton

Class ProtonProducer

java.lang.Object

org.hornetq.core.protocol.proton.ProtonProducer

All Implemented Interfaces:

ProtonDeliveryHandler

public class ProtonProducer
extends Object
implements ProtonDeliveryHandler

Author:

Andy Taylor

handles incoming messages via a Proton Receiver and forwards them to HornetQ

Constructor Summary

Constructors

Constructor and Description
ProtonProducer(ProtonRemotingConnection connection, ProtonSession protonSession, ProtonProtocolManager protonProtocolManager, org.apache.qpid.proton.engine.Receiver receiver)

Method Summary

Methods

Modifier and Type	Method and Description
void	checkState()
void	close()
void	init()
void	onMessage(org.apache.qpid.proton.engine.Delivery delivery)

Methods inherited from class java.lang.Object

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

Constructor Detail

ProtonProducer

public ProtonProducer(ProtonRemotingConnection connection,
              ProtonSession protonSession,
              ProtonProtocolManager protonProtocolManager,
              org.apache.qpid.proton.engine.Receiver receiver)

Method Detail

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

close

public void close()
           throws HornetQAMQPException

Specified by:

close in interface ProtonDeliveryHandler

Throws:

HornetQAMQPException

init

public void init()
          throws HornetQAMQPException

Throws:

HornetQAMQPException