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

Source.setFilter介绍

暂无

代码示例

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

o.setDefaultOutcome( (Outcome) l.get( 8 ) );
case 3:
  o.setFilter( (Map) l.get( 7 ) );
case 4:
  o.setDistributionMode( (Symbol) l.get( 6 ) );

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

o.setDefaultOutcome( (Outcome) l.get( 8 ) );
case 3:
  o.setFilter( (Map) l.get( 7 ) );
case 4:
  o.setDistributionMode( (Symbol) l.get( 6 ) );

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

o.setDefaultOutcome( (Outcome) l.get( 8 ) );
case 3:
  o.setFilter( (Map) l.get( 7 ) );
case 4:
  o.setDistributionMode( (Symbol) l.get( 6 ) );

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

o.setDefaultOutcome( (Outcome) l.get( 8 ) );
case 3:
  o.setFilter( (Map) l.get( 7 ) );
case 4:
  o.setDistributionMode( (Symbol) l.get( 6 ) );

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

source.setFilter(filters);

代码示例来源：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: apache/qpid-jms

source.setFilter(filters);

代码示例来源：origin: Azure/azure-service-bus-java

source.setFilter(filterMap);

代码示例来源：origin: org.apache.activemq/activemq-osgi

source.setFilter(supportedFilters.isEmpty() ? null : supportedFilters);
protonSender.setSource(source);

代码示例来源：origin: org.apache.activemq/activemq-all

source.setFilter(supportedFilters.isEmpty() ? null : supportedFilters);
protonSender.setSource(source);

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

source.setFilter(supportedFilters.isEmpty() ? null : supportedFilters);

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

source.setFilter(supportedFilters.isEmpty() ? null : supportedFilters);

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

source.setFilter(filters);
source.setDurable(TerminusDurability.NONE);
source.setExpiryPolicy(TerminusExpiryPolicy.LINK_DETACH);

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

source.setFilter(filters);
source.setDurable(TerminusDurability.NONE);
source.setExpiryPolicy(TerminusExpiryPolicy.LINK_DETACH);

代码示例来源：origin: Azure/azure-event-hubs-java

source.setFilter(filterMap);