本文整理了Java中org.apache.qpid.proton.engine.Receiver.current方法的一些代码示例，展示了Receiver.current的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Receiver.current方法的具体详情如下：
包路径：org.apache.qpid.proton.engine.Receiver
类名称：Receiver
方法名：current

Receiver.current介绍

暂无

代码示例

代码示例来源：origin: Azure/azure-iot-sdk-java

Delivery delivery = this.receiverLink.current();
if (linkName.equals(this.receiverLinkTag) && (delivery != null) && delivery.isReadable() && !delivery.isPartial())

代码示例来源：origin: com.microsoft.azure.iot/proton-j-azure-iot

private int pumpIn(String address, Receiver receiver)
  Delivery delivery = receiver.current();
  if (delivery.isReadable() && !delivery.isPartial())

代码示例来源：origin: org.apache.qpid/proton-j-impl

private int pumpIn(String address, Receiver receiver)
  Delivery delivery = receiver.current();
  if (delivery.isReadable() && !delivery.isPartial())

代码示例来源：origin: Azure/azure-iot-sdk-java

Delivery delivery = this.receiverLink.current();

代码示例来源：origin: apache/activemq-artemis

Delivery incoming = null;
do {
  incoming = getEndpoint().current();
  if (incoming != null) {
   if (incoming.isReadable() && !incoming.isPartial()) {

代码示例来源：origin: org.apache.qpid/qpid-jms-client

@Override
public void processDeliveryUpdates(AmqpProvider provider, Delivery delivery) throws IOException {
  if (delivery.isReadable() && !delivery.isPartial()) {
    LOG.trace("{} has incoming Message(s).", this);
    try {
      if (processDelivery(delivery)) {
        // We processed a message, signal completion
        // of a message pull request if there is one.
        if (pullRequest != null) {
          pullRequest.onSuccess();
          pullRequest = null;
        }
      }
    } catch (Exception e) {
      throw IOExceptionSupport.create(e);
    }
  }
  if (getEndpoint().current() == null) {
    // We have exhausted the locally queued messages on this link.
    // Check if we tried to stop and have now run out of credit.
    if (getEndpoint().getRemoteCredit() <= 0) {
      if (stopRequest != null) {
        stopRequest.onSuccess();
        stopRequest = null;
      }
    }
  }
  super.processDeliveryUpdates(provider, delivery);
}

代码示例来源：origin: apache/qpid-jms

@Override
public void processDeliveryUpdates(AmqpProvider provider, Delivery delivery) throws IOException {
  if (delivery.isReadable() && !delivery.isPartial()) {
    LOG.trace("{} has incoming Message(s).", this);
    try {
      if (processDelivery(delivery)) {
        // We processed a message, signal completion
        // of a message pull request if there is one.
        if (pullRequest != null) {
          pullRequest.onSuccess();
          pullRequest = null;
        }
      }
    } catch (Exception e) {
      throw IOExceptionSupport.create(e);
    }
  }
  if (getEndpoint().current() == null) {
    // We have exhausted the locally queued messages on this link.
    // Check if we tried to stop and have now run out of credit.
    if (getEndpoint().getRemoteCredit() <= 0) {
      if (stopRequest != null) {
        stopRequest.onSuccess();
        stopRequest = null;
      }
    }
  }
  super.processDeliveryUpdates(provider, delivery);
}

代码示例来源：origin: com.microsoft.azure.iothub-java-client/iothub-java-device-client

Delivery delivery = receiveLink.current();
if (delivery.isReadable() && !delivery.isPartial()) {

代码示例来源：origin: Azure/azure-iot-sdk-java

Delivery delivery = recv.current();
if (delivery.isReadable() && !delivery.isPartial() && delivery.getLink().getName().equals(RECEIVE_TAG))

代码示例来源：origin: org.apache.activemq/artemis-amqp-protocol

Receiver receiver = ((Receiver) delivery.getLink());
if (receiver.current() != delivery) {
 return;

代码示例来源：origin: apache/activemq-artemis

@Override
public void onMessage(Delivery delivery) throws ActiveMQAMQPException {
 connection.requireInHandler();
 Receiver receiver = ((Receiver) delivery.getLink());
 if (receiver.current() != delivery) {
   return;
 }
 if (delivery.isAborted()) {
   // Aborting implicitly remotely settles, so advance
   // receiver to the next delivery and settle locally.
   receiver.advance();
   delivery.settle();
   // Replenish the credit if not doing a drain
   if (!receiver.getDrain()) {
    receiver.flow(1);
   }
   return;
 } else if (delivery.isPartial()) {
   return;
 }
 ReadableBuffer data = receiver.recv();
 receiver.advance();
 Transaction tx = null;
 if (delivery.getRemoteState() instanceof TransactionalState) {
   TransactionalState txState = (TransactionalState) delivery.getRemoteState();
   tx = this.sessionSPI.getTransaction(txState.getTxnId(), false);
 }
 final Transaction txUsed = tx;
 actualDelivery(delivery, receiver, data, txUsed);
}

代码示例来源：origin: Azure/azure-iot-sdk-java

Delivery delivery = recv.current();

代码示例来源：origin: io.vertx/vertx-proton

Delivery delivery = receiver.current();