public interface ProtonSubscriber<T>
extends org.reactivestreams.Subscriber<T>
| Modifier and Type | Method and Description |
|---|---|
org.apache.qpid.proton.amqp.transport.Source |
getSource()
Retrieves the local Source details for access or customisation.
|
org.apache.qpid.proton.amqp.transport.Target |
getTarget()
Retrieves the local Target details for access or customisation.
|
ProtonSubscriber<T> |
setSource(org.apache.qpid.proton.amqp.transport.Source source)
Sets the local Source details.
|
ProtonSubscriber<T> |
setTarget(org.apache.qpid.proton.amqp.transport.Target target)
Sets the local Target details.
|
ProtonSubscriber<T> setTarget(org.apache.qpid.proton.amqp.transport.Target target)
target - the targetorg.apache.qpid.proton.amqp.transport.Target getTarget()
ProtonSubscriber<T> setSource(org.apache.qpid.proton.amqp.transport.Source source)
source - the sourceorg.apache.qpid.proton.amqp.transport.Source getSource()
Copyright © 2020. All rights reserved.