org.apache.qpid.proton.amqp.messaging.Source.getAddress()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(10.6k)|赞(0)|评价(0)|浏览(175)

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

Source.getAddress介绍

暂无

代码示例

代码示例来源：origin: vert-x3/vertx-examples

if(!sender.sendQueueFull()) {
 int msgNum = sent.incrementAndGet();
 System.out.println("Sending message " + msgNum + " to client, for address: " + remoteSource.getAddress());
 Message m = message("Hello " + msgNum + " from Server!");
 sender.send(m, delivery -> {

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

private static boolean matchSource(Source source, String path)
{
  if (source == null) return path.isEmpty();
  else return path.equals(source.getAddress());
}

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

private static boolean matchSource(Source source, String path)
{
  if (source == null) return path.isEmpty();
  else return path.equals(source.getAddress());
}

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

private static boolean matchSource(Source source, String path)
{
  if (source == null) return path.isEmpty();
  else return path.equals(source.getAddress());
}

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

/**
* Create a new receiver instance.
*
* @param session
*        The parent session that created the receiver.
* @param source
*        The Source instance to use instead of creating and configuring one.
* @param receiverId
*        The unique ID assigned to this receiver.
*/
public AmqpReceiver(AmqpSession session, Source source, String receiverId) {
 if (source == null) {
   throw new IllegalArgumentException("User specified Source cannot be null");
 }
 this.session = session;
 this.address = source.getAddress();
 this.receiverId = receiverId;
 this.userSpecifiedSource = source;
 this.userSpecifiedSenderSettlementMode = null;
 this.userSpecifiedReceiverSettlementMode = null;
}

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

private boolean isPubSub(Source source) {
 String pubSubPrefix = sessionSPI.getPubSubPrefix();
 return source != null && pubSubPrefix != null && source.getAddress() != null && source.getAddress().startsWith(pubSubPrefix);
}

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

@Override
public void close(boolean remoteLinkClose) throws ActiveMQAMQPException {
 super.close(remoteLinkClose);
 try {
   sessionSPI.closeSender(brokerConsumer);
   //if this is a link close rather than a connection close or detach, we need to delete any durable resources for
   // say pub subs
   if (remoteLinkClose ) {
    Source source = (Source)sender.getSource();
    if (source != null && source.getAddress() != null && hasCapabilities(TOPIC, source)) {
      String address = source.getAddress();
      boolean exists = sessionSPI.queueQuery(address);
      if (exists) {
       sessionSPI.deleteQueue(address);
      }
    }
   }
 }
 catch (Exception e) {
   log.warn(e.getMessage(), e);
   throw new ActiveMQAMQPInternalErrorException(e.getMessage());
 }
}

代码示例来源：origin: EnMasseProject/enmasse

public ReceiverStatus recvMessages(Source source, Predicate<Message> done, Optional<String> linkName) {
  CompletableFuture<List<Message>> resultPromise = new CompletableFuture<>();
  Vertx vertx = VertxFactory.create();
  clients.add(vertx);
  String containerId = "systemtest-receiver-" + source.getAddress();
  CompletableFuture<Void> connectPromise = new CompletableFuture<>();
  Receiver receiver = new Receiver(options, done, new LinkOptions(source, new Target(), linkName), connectPromise, resultPromise, containerId);
  vertx.deployVerticle(receiver);
  try {
    connectPromise.get(2, TimeUnit.MINUTES);
  } catch (Exception e) {
    resultPromise.completeExceptionally(e);
  }
  return new ReceiverStatus() {
    @Override
    public Future<List<Message>> getResult() {
      return resultPromise;
    }
    @Override
    public int getNumReceived() {
      return receiver.getNumReceived();
    }
  };
}

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

@Override
public String toString()
{
  return "Source{" +
      "address='" + getAddress() + '\'' +
      ", durable=" + getDurable() +
      ", expiryPolicy=" + getExpiryPolicy() +
      ", timeout=" + getTimeout() +
      ", dynamic=" + getDynamic() +
      ", dynamicNodeProperties=" + getDynamicNodeProperties() +
      ", distributionMode=" + _distributionMode +
      ", filter=" + _filter +
      ", defaultOutcome=" + _defaultOutcome +
      ", outcomes=" + (_outcomes == null ? null : Arrays.asList(_outcomes)) +
      ", capabilities=" + (getCapabilities() == null ? null : Arrays.asList(getCapabilities())) +
      '}';
}

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

@Override
public String toString()
{
  return "Source{" +
      "address='" + getAddress() + '\'' +
      ", durable=" + getDurable() +
      ", expiryPolicy=" + getExpiryPolicy() +
      ", timeout=" + getTimeout() +
      ", dynamic=" + getDynamic() +
      ", dynamicNodeProperties=" + getDynamicNodeProperties() +
      ", distributionMode=" + _distributionMode +
      ", filter=" + _filter +
      ", defaultOutcome=" + _defaultOutcome +
      ", outcomes=" + (_outcomes == null ? null : Arrays.asList(_outcomes)) +
      ", capabilities=" + (getCapabilities() == null ? null : Arrays.asList(getCapabilities())) +
      '}';
}

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

@Override
  public String toString()
  {
    return "Source{" +
        "address='" + getAddress() + '\'' +
        ", durable=" + getDurable() +
        ", expiryPolicy=" + getExpiryPolicy() +
        ", timeout=" + getTimeout() +
        ", dynamic=" + getDynamic() +
        ", dynamicNodeProperties=" + getDynamicNodeProperties() +
        ", distributionMode=" + _distributionMode +
        ", filter=" + _filter +
        ", defaultOutcome=" + _defaultOutcome +
        ", outcomes=" + (_outcomes == null ? null : Arrays.asList(_outcomes)) +
        ", capabilities=" + (getCapabilities() == null ? null : Arrays.asList(getCapabilities())) +
        '}';
  }
}

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

public Object get(final int index)
{
  switch(index)
  {
    case 0:
      return _impl.getAddress();
    case 1:
      return _impl.getDurable().getValue();
    case 2:
      return _impl.getExpiryPolicy().getPolicy();
    case 3:
      return _impl.getTimeout();
    case 4:
      return _impl.getDynamic();
    case 5:
      return _impl.getDynamicNodeProperties();
    case 6:
      return _impl.getDistributionMode();
    case 7:
      return _impl.getFilter();
    case 8:
      return _impl.getDefaultOutcome();
    case 9:
      return _impl.getOutcomes();
    case 10:
      return _impl.getCapabilities();
  }
  throw new IllegalStateException("Unknown index " + index);
}

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

public Object get(final int index)
{
  switch(index)
  {
    case 0:
      return _impl.getAddress();
    case 1:
      return _impl.getDurable().getValue();
    case 2:
      return _impl.getExpiryPolicy().getPolicy();
    case 3:
      return _impl.getTimeout();
    case 4:
      return _impl.getDynamic();
    case 5:
      return _impl.getDynamicNodeProperties();
    case 6:
      return _impl.getDistributionMode();
    case 7:
      return _impl.getFilter();
    case 8:
      return _impl.getDefaultOutcome();
    case 9:
      return _impl.getOutcomes();
    case 10:
      return _impl.getCapabilities();
  }
  throw new IllegalStateException("Unknown index " + index);
}

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

public Object get(final int index)
{
  switch(index)
  {
    case 0:
      return _impl.getAddress();
    case 1:
      return _impl.getDurable().getValue();
    case 2:
      return _impl.getExpiryPolicy().getPolicy();
    case 3:
      return _impl.getTimeout();
    case 4:
      return _impl.getDynamic();
    case 5:
      return _impl.getDynamicNodeProperties();
    case 6:
      return _impl.getDistributionMode();
    case 7:
      return _impl.getFilter();
    case 8:
      return _impl.getDefaultOutcome();
    case 9:
      return _impl.getOutcomes();
    case 10:
      return _impl.getCapabilities();
  }
  throw new IllegalStateException("Unknown index " + index);
}

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

public Object get(final int index)
{
  switch(index)
  {
    case 0:
      return _impl.getAddress();
    case 1:
      return _impl.getDurable().getValue();
    case 2:
      return _impl.getExpiryPolicy().getPolicy();
    case 3:
      return _impl.getTimeout();
    case 4:
      return _impl.getDynamic();
    case 5:
      return _impl.getDynamicNodeProperties();
    case 6:
      return _impl.getDistributionMode();
    case 7:
      return _impl.getFilter();
    case 8:
      return _impl.getDefaultOutcome();
    case 9:
      return _impl.getOutcomes();
    case 10:
      return _impl.getCapabilities();
  }
  throw new IllegalStateException("Unknown index " + index);
}

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

public int size()
{
  return _impl.getCapabilities() != null
       ? 11
       : _impl.getOutcomes() != null
       ? 10
       : _impl.getDefaultOutcome() != null
       ? 9
       : _impl.getFilter() != null
       ? 8
       : _impl.getDistributionMode() != null
       ? 7
       : _impl.getDynamicNodeProperties() != null
       ? 6
       : _impl.getDynamic()
       ? 5
       : (_impl.getTimeout() != null && !_impl.getTimeout().equals(UnsignedInteger.ZERO))
       ? 4
       : _impl.getExpiryPolicy() != TerminusExpiryPolicy.SESSION_END
       ? 3
       : _impl.getDurable() != TerminusDurability.NONE
       ? 2
       : _impl.getAddress() != null
       ? 1
       : 0;
}

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

public int size()
{
  return _impl.getCapabilities() != null
       ? 11
       : _impl.getOutcomes() != null
       ? 10
       : _impl.getDefaultOutcome() != null
       ? 9
       : _impl.getFilter() != null
       ? 8
       : _impl.getDistributionMode() != null
       ? 7
       : _impl.getDynamicNodeProperties() != null
       ? 6
       : _impl.getDynamic()
       ? 5
       : (_impl.getTimeout() != null && !_impl.getTimeout().equals(UnsignedInteger.ZERO))
       ? 4
       : _impl.getExpiryPolicy() != TerminusExpiryPolicy.SESSION_END
       ? 3
       : _impl.getDurable() != TerminusDurability.NONE
       ? 2
       : _impl.getAddress() != null
       ? 1
       : 0;
}

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

protected void doTestDynamicReceiverLifetimeBoundToLinkQueue(boolean topic) throws Exception {
 Source source = createDynamicSource(topic);
 AmqpClient client = createAmqpClient();
 AmqpConnection connection = addConnection(client.connect());
 AmqpSession session = connection.createSession();
 AmqpReceiver receiver = session.createReceiver(source);
 assertNotNull(receiver);
 Source remoteSource = (Source) receiver.getEndpoint().getRemoteSource();
 Queue queueView = getProxyToQueue(remoteSource.getAddress());
 assertNotNull(queueView);
 receiver.close();
 queueView = getProxyToQueue(remoteSource.getAddress());
 assertNull(queueView);
 connection.close();
}

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

@SuppressWarnings("unchecked")
protected void doTestCreateDynamicReceiver(boolean topic) throws Exception {
 Source source = createDynamicSource(topic);
 AmqpClient client = createAmqpClient();
 AmqpConnection connection = addConnection(client.connect());
 AmqpSession session = connection.createSession();
 AmqpReceiver receiver = session.createReceiver(source);
 assertNotNull(receiver);
 Source remoteSource = (Source) receiver.getEndpoint().getRemoteSource();
 assertTrue(remoteSource.getDynamic());
 assertTrue(remoteSource.getDurable().equals(TerminusDurability.NONE));
 assertTrue(remoteSource.getExpiryPolicy().equals(TerminusExpiryPolicy.LINK_DETACH));
 // Check the dynamic node lifetime-policy
 Map<Symbol, Object> dynamicNodeProperties = remoteSource.getDynamicNodeProperties();
 assertTrue(dynamicNodeProperties.containsKey(LIFETIME_POLICY));
 assertEquals(DeleteOnClose.getInstance(), dynamicNodeProperties.get(LIFETIME_POLICY));
 Queue queueView = getProxyToQueue(remoteSource.getAddress());
 assertNotNull(queueView);
 connection.close();
}

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

Queue queueView = getProxyToQueue(remoteSource.getAddress());
assertNotNull(queueView);

内容来源于网络，如有侵权，请联系作者删除！

source

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com