public interface AmqpEventSink
Modifier and Type | Method and Description |
---|---|
void |
processDeliveryUpdates(AmqpProvider provider)
Called when the Proton Engine signals an Delivery related event has been triggered
for the given endpoint.
|
void |
processFlowUpdates(AmqpProvider provider)
Called when the Proton Engine signals an Flow related event has been triggered
for the given endpoint.
|
void |
processRemoteClose(AmqpProvider provider)
Event handler for remote peer close of this resource.
|
void |
processRemoteDetach(AmqpProvider provider)
Event handler for remote peer detach of this resource.
|
void |
processRemoteOpen(AmqpProvider provider)
Event handler for remote peer open of this resource.
|
void processRemoteOpen(AmqpProvider provider) throws IOException
provider
- the AmqpProvider instance for easier access to fire events.IOException
- if an error occurs while processing the update.void processRemoteDetach(AmqpProvider provider) throws IOException
provider
- the AmqpProvider instance for easier access to fire events.IOException
- if an error occurs while processing the update.void processRemoteClose(AmqpProvider provider) throws IOException
provider
- the AmqpProvider instance for easier access to fire events.IOException
- if an error occurs while processing the update.void processDeliveryUpdates(AmqpProvider provider) throws IOException
provider
- the AmqpProvider instance for easier access to fire events.IOException
- if an error occurs while processing the update.void processFlowUpdates(AmqpProvider provider) throws IOException
provider
- the AmqpProvider instance for easier access to fire events.IOException
- if an error occurs while processing the update.Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.