public class ProtonPublisherImpl extends Object implements ProtonPublisher<Delivery>
| Modifier and Type | Class and Description |
|---|---|
class |
ProtonPublisherImpl.AmqpSubscription |
| Constructor and Description |
|---|
ProtonPublisherImpl(String address,
ProtonConnectionImpl conn,
ProtonPublisherOptions options) |
| Modifier and Type | Method and Description |
|---|---|
ProtonReceiver |
getLink() |
String |
getRemoteAddress()
Retrieves the address from the remote source details.
|
org.apache.qpid.proton.amqp.transport.Source |
getRemoteSource()
Retrieves the remote Source details.
|
org.apache.qpid.proton.amqp.transport.Target |
getRemoteTarget()
Retrieves the remote Target details.
|
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.
|
boolean |
isEmitOnConnectionEnd() |
void |
setEmitOnConnectionEnd(boolean emitOnConnectionEnd) |
ProtonPublisher<Delivery> |
setSource(org.apache.qpid.proton.amqp.transport.Source source)
Sets the local Source details.
|
ProtonPublisher<Delivery> |
setTarget(org.apache.qpid.proton.amqp.transport.Target target)
Sets the local Target details.
|
void |
subscribe(org.reactivestreams.Subscriber<? super Delivery> subscriber) |
public ProtonPublisherImpl(String address, ProtonConnectionImpl conn, ProtonPublisherOptions options)
public void subscribe(org.reactivestreams.Subscriber<? super Delivery> subscriber)
subscribe in interface org.reactivestreams.Publisher<Delivery>public boolean isEmitOnConnectionEnd()
public void setEmitOnConnectionEnd(boolean emitOnConnectionEnd)
public ProtonReceiver getLink()
public ProtonPublisher<Delivery> setSource(org.apache.qpid.proton.amqp.transport.Source source)
ProtonPublishersetSource in interface ProtonPublisher<Delivery>source - the sourcepublic org.apache.qpid.proton.amqp.transport.Source getSource()
ProtonPublishergetSource in interface ProtonPublisher<Delivery>public ProtonPublisher<Delivery> setTarget(org.apache.qpid.proton.amqp.transport.Target target)
ProtonPublishersetTarget in interface ProtonPublisher<Delivery>target - the targetpublic org.apache.qpid.proton.amqp.transport.Target getTarget()
ProtonPublishergetTarget in interface ProtonPublisher<Delivery>public org.apache.qpid.proton.amqp.transport.Source getRemoteSource()
ProtonPublishergetRemoteSource in interface ProtonPublisher<Delivery>public org.apache.qpid.proton.amqp.transport.Target getRemoteTarget()
ProtonPublishergetRemoteTarget in interface ProtonPublisher<Delivery>public String getRemoteAddress()
ProtonPublishergetRemoteAddress in interface ProtonPublisher<Delivery>Copyright © 2020. All rights reserved.