本文整理了Java中org.apache.qpid.proton.amqp.messaging.Source.setDynamicNodeProperties()
方法的一些代码示例,展示了Source.setDynamicNodeProperties()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Source.setDynamicNodeProperties()
方法的具体详情如下:
包路径:org.apache.qpid.proton.amqp.messaging.Source
类名称:Source
方法名:setDynamicNodeProperties
暂无
代码示例来源:origin: org.apache.qpid/proton
o.setDistributionMode( (Symbol) l.get( 6 ) );
case 5:
o.setDynamicNodeProperties( (Map) l.get( 5 ) );
case 6:
Boolean dynamic = (Boolean) l.get(4);
代码示例来源:origin: org.apache.qpid/proton-j-impl
o.setDistributionMode( (Symbol) l.get( 6 ) );
case 5:
o.setDynamicNodeProperties( (Map) l.get( 5 ) );
case 6:
Boolean dynamic = (Boolean) l.get(4);
代码示例来源:origin: org.apache.qpid/proton-j
o.setDistributionMode( (Symbol) l.get( 6 ) );
case 5:
o.setDynamicNodeProperties( (Map) l.get( 5 ) );
case 6:
Boolean dynamic = (Boolean) l.get(4);
代码示例来源:origin: com.microsoft.azure.iot/proton-j-azure-iot
o.setDistributionMode( (Symbol) l.get( 6 ) );
case 5:
o.setDynamicNodeProperties( (Map) l.get( 5 ) );
case 6:
Boolean dynamic = (Boolean) l.get(4);
代码示例来源:origin: apache/activemq-artemis
protected Source createDynamicSource(boolean topic) {
Source source = new Source();
source.setDynamic(true);
source.setDurable(TerminusDurability.NONE);
source.setExpiryPolicy(TerminusExpiryPolicy.LINK_DETACH);
// Set the dynamic node lifetime-policy
Map<Symbol, Object> dynamicNodeProperties = new HashMap<>();
dynamicNodeProperties.put(LIFETIME_POLICY, DeleteOnClose.getInstance());
source.setDynamicNodeProperties(dynamicNodeProperties);
// Set the capability to indicate the node type being created
if (!topic) {
source.setCapabilities(TEMP_QUEUE_CAPABILITY);
} else {
source.setCapabilities(TEMP_TOPIC_CAPABILITY);
}
return source;
}
代码示例来源:origin: org.apache.activemq/activemq-all
source.setCapabilities(AmqpSupport.getDestinationTypeSymbol(destination));
source.setDynamic(true);
source.setDynamicNodeProperties(dynamicNodeProperties);
代码示例来源:origin: org.apache.activemq/activemq-osgi
source.setCapabilities(AmqpSupport.getDestinationTypeSymbol(destination));
source.setDynamic(true);
source.setDynamicNodeProperties(dynamicNodeProperties);
内容来源于网络,如有侵权,请联系作者删除!