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

Source.setOutcomes介绍

暂无

代码示例

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

if( val1 == null || val1.getClass().isArray() )
  o.setOutcomes( (Symbol[]) val1 );
  o.setOutcomes( (Symbol) val1 );

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

if( val1 == null || val1.getClass().isArray() )
  o.setOutcomes( (Symbol[]) val1 );
  o.setOutcomes( (Symbol) val1 );

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

if( val1 == null || val1.getClass().isArray() )
  o.setOutcomes( (Symbol[]) val1 );
  o.setOutcomes( (Symbol) val1 );

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

if( val1 == null || val1.getClass().isArray() )
  o.setOutcomes( (Symbol[]) val1 );
  o.setOutcomes( (Symbol) val1 );

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

protected void configureSource(Source source) {
 Map<Symbol, DescribedType> filters = new HashMap<>();
 Symbol[] outcomes = new Symbol[] {Accepted.DESCRIPTOR_SYMBOL, Rejected.DESCRIPTOR_SYMBOL, Released.DESCRIPTOR_SYMBOL, Modified.DESCRIPTOR_SYMBOL};
 if (getSubscriptionName() != null && !getSubscriptionName().isEmpty()) {
   source.setExpiryPolicy(TerminusExpiryPolicy.NEVER);
   source.setDurable(TerminusDurability.UNSETTLED_STATE);
   source.setDistributionMode(COPY);
 } else {
   source.setDurable(TerminusDurability.NONE);
   source.setExpiryPolicy(TerminusExpiryPolicy.LINK_DETACH);
 }
 source.setOutcomes(outcomes);
 Modified modified = new Modified();
 modified.setDeliveryFailed(true);
 modified.setUndeliverableHere(false);
 source.setDefaultOutcome(modified);
 if (isNoLocal()) {
   filters.put(NO_LOCAL_NAME, AmqpNoLocalFilter.NO_LOCAL);
 }
 if (getSelector() != null && !getSelector().trim().equals("")) {
   filters.put(JMS_SELECTOR_NAME, new AmqpJmsSelectorFilter(getSelector()));
 }
 if (!filters.isEmpty()) {
   source.setFilter(filters);
 }
}

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

source.setOutcomes(outcomes);
source.setDefaultOutcome(MODIFIED_FAILED);

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

source.setOutcomes(outcomes);
source.setDefaultOutcome(MODIFIED_FAILED);

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

Source source = new Source();
source.setAddress(senderName);
source.setOutcomes(outcomes);

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

@Override
public ProtonReceiver createReceiver(String address, ProtonLinkOptions receiverOptions) {
 Receiver receiver = session.receiver(getOrCreateLinkName(receiverOptions));
 Symbol[] outcomes = new Symbol[] { Accepted.DESCRIPTOR_SYMBOL, Rejected.DESCRIPTOR_SYMBOL,
   Released.DESCRIPTOR_SYMBOL, Modified.DESCRIPTOR_SYMBOL };
 Source source = new Source();
 source.setAddress(address);
 source.setOutcomes(outcomes);
 source.setDefaultOutcome(Released.getInstance());
 if(receiverOptions.isDynamic()) {
  source.setDynamic(true);
 }
 Target target = new Target();
 receiver.setSource(source);
 receiver.setTarget(target);
 ProtonReceiverImpl r = new ProtonReceiverImpl(receiver);
 r.openHandler((result) -> {
  LOG.trace("Receiver open completed");
 });
 r.closeHandler((result) -> {
  if (result.succeeded()) {
   LOG.trace("Receiver closed");
  } else {
   LOG.warn("Receiver closed with error", result.cause());
  }
 });
 // Default to at-least-once
 r.setQoS(ProtonQoS.AT_LEAST_ONCE);
 return r;
}

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

Released.DESCRIPTOR_SYMBOL, Modified.DESCRIPTOR_SYMBOL };
Source source = new Source();
source.setOutcomes(outcomes);

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

@Override
protected Sender createEndpoint(JmsSessionInfo resourceInfo) {
  Coordinator coordinator = new Coordinator();
  coordinator.setCapabilities(TxnCapability.LOCAL_TXN);
  Symbol[] outcomes = new Symbol[]{ Accepted.DESCRIPTOR_SYMBOL, Rejected.DESCRIPTOR_SYMBOL, Released.DESCRIPTOR_SYMBOL, Modified.DESCRIPTOR_SYMBOL };
  Source source = new Source();
  source.setOutcomes(outcomes);
  String coordinatorName = "qpid-jms:coordinator:" + resourceInfo.getId().toString();
  Sender sender = getParent().getSession().getEndpoint().sender(coordinatorName);
  sender.setSource(source);
  sender.setTarget(coordinator);
  sender.setSenderSettleMode(SenderSettleMode.UNSETTLED);
  sender.setReceiverSettleMode(ReceiverSettleMode.FIRST);
  return sender;
}

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

@Override
protected Sender createEndpoint(JmsSessionInfo resourceInfo) {
  Coordinator coordinator = new Coordinator();
  coordinator.setCapabilities(TxnCapability.LOCAL_TXN);
  Symbol[] outcomes = new Symbol[]{ Accepted.DESCRIPTOR_SYMBOL, Rejected.DESCRIPTOR_SYMBOL, Released.DESCRIPTOR_SYMBOL, Modified.DESCRIPTOR_SYMBOL };
  Source source = new Source();
  source.setOutcomes(outcomes);
  String coordinatorName = "qpid-jms:coordinator:" + resourceInfo.getId().toString();
  Sender sender = getParent().getSession().getEndpoint().sender(coordinatorName);
  sender.setSource(source);
  sender.setTarget(coordinator);
  sender.setSenderSettleMode(SenderSettleMode.UNSETTLED);
  sender.setReceiverSettleMode(ReceiverSettleMode.FIRST);
  return sender;
}

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

Source source = new Source();
source.setAddress(senderId);
source.setOutcomes(outcomes);

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

Source source = new Source();
source.setAddress(sourceAddress);
source.setOutcomes(outcomes);

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

Source source = new Source();
source.setAddress(sourceAddress);
source.setOutcomes(outcomes);