本文整理了Java中org.apache.qpid.proton.amqp.messaging.Header.setFirstAcquirer()
方法的一些代码示例,展示了Header.setFirstAcquirer()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Header.setFirstAcquirer()
方法的具体详情如下:
包路径:org.apache.qpid.proton.amqp.messaging.Header
类名称:Header
方法名:setFirstAcquirer
暂无
代码示例来源:origin: org.apache.qpid/proton-j
@Override
public void setFirstAcquirer(boolean firstAcquirer)
{
if (_header == null)
{
if (!firstAcquirer)
{
return;
}
_header = new Header();
}
_header.setFirstAcquirer(firstAcquirer);
}
代码示例来源:origin: org.apache.qpid/proton-j-impl
@Override
public void setFirstAcquirer(boolean firstAcquirer)
{
if (_header == null)
{
if (!firstAcquirer)
{
return;
}
_header = new Header();
}
_header.setFirstAcquirer(firstAcquirer);
}
代码示例来源:origin: com.microsoft.azure.iot/proton-j-azure-iot
@Override
public void setFirstAcquirer(boolean firstAcquirer)
{
if (_header == null)
{
if (!firstAcquirer)
{
return;
}
_header = new Header();
}
_header.setFirstAcquirer(firstAcquirer);
}
代码示例来源:origin: org.apache.qpid/proton
@Override
public void setFirstAcquirer(boolean firstAcquirer)
{
if (_header == null)
{
if (!firstAcquirer)
{
return;
}
_header = new Header();
}
_header.setFirstAcquirer(firstAcquirer);
}
代码示例来源:origin: org.apache.qpid/proton-j
public Header newInstance(Object described)
{
List l = (List) described;
Header o = new Header();
switch(5 - l.size())
{
case 0:
o.setDeliveryCount( (UnsignedInteger) l.get( 4 ) );
case 1:
o.setFirstAcquirer( (Boolean) l.get( 3 ) );
case 2:
o.setTtl( (UnsignedInteger) l.get( 2 ) );
case 3:
o.setPriority( (UnsignedByte) l.get( 1 ) );
case 4:
o.setDurable( (Boolean) l.get( 0 ) );
}
return o;
}
代码示例来源:origin: org.apache.qpid/proton-j-impl
public Header newInstance(Object described)
{
List l = (List) described;
Header o = new Header();
switch(5 - l.size())
{
case 0:
o.setDeliveryCount( (UnsignedInteger) l.get( 4 ) );
case 1:
o.setFirstAcquirer( (Boolean) l.get( 3 ) );
case 2:
o.setTtl( (UnsignedInteger) l.get( 2 ) );
case 3:
o.setPriority( (UnsignedByte) l.get( 1 ) );
case 4:
o.setDurable( (Boolean) l.get( 0 ) );
}
return o;
}
代码示例来源:origin: com.microsoft.azure.iot/proton-j-azure-iot
public Header newInstance(Object described)
{
List l = (List) described;
Header o = new Header();
switch(5 - l.size())
{
case 0:
o.setDeliveryCount( (UnsignedInteger) l.get( 4 ) );
case 1:
o.setFirstAcquirer( (Boolean) l.get( 3 ) );
case 2:
o.setTtl( (UnsignedInteger) l.get( 2 ) );
case 3:
o.setPriority( (UnsignedByte) l.get( 1 ) );
case 4:
o.setDurable( (Boolean) l.get( 0 ) );
}
return o;
}
代码示例来源:origin: org.apache.qpid/proton
public Header newInstance(Object described)
{
List l = (List) described;
Header o = new Header();
switch(5 - l.size())
{
case 0:
o.setDeliveryCount( (UnsignedInteger) l.get( 4 ) );
case 1:
o.setFirstAcquirer( (Boolean) l.get( 3 ) );
case 2:
o.setTtl( (UnsignedInteger) l.get( 2 ) );
case 3:
o.setPriority( (UnsignedByte) l.get( 1 ) );
case 4:
o.setDurable( (Boolean) l.get( 0 ) );
}
return o;
}
代码示例来源:origin: apache/qpid-jms
public Header getHeader() {
Header result = null;
if (!isDefault()) {
result = new Header();
result.setDurable(durable);
result.setPriority(priority);
result.setFirstAcquirer(firstAcquirer);
result.setTtl(timeToLive);
result.setDeliveryCount(deliveryCount);
}
return result;
}
代码示例来源:origin: org.apache.qpid/qpid-jms-client
public Header getHeader() {
Header result = null;
if (!isDefault()) {
result = new Header();
result.setDurable(durable);
result.setPriority(priority);
result.setFirstAcquirer(firstAcquirer);
result.setTtl(timeToLive);
result.setDeliveryCount(deliveryCount);
}
return result;
}
代码示例来源:origin: org.apache.qpid/proton-jms
header.setFirstAcquirer(msg.getBooleanProperty(key));
} else if( key.startsWith("JMSXDeliveryCount") ) {
代码示例来源:origin: org.apache.activemq/activemq-osgi
header = new Header();
header.setFirstAcquirer((boolean) TypeConversionSupport.convert(value, Boolean.class));
continue;
} else if (key.startsWith(CONTENT_TYPE, JMS_AMQP_PREFIX_LENGTH)) {
代码示例来源:origin: org.apache.activemq/activemq-all
header = new Header();
header.setFirstAcquirer((boolean) TypeConversionSupport.convert(value, Boolean.class));
continue;
} else if (key.startsWith(CONTENT_TYPE, JMS_AMQP_PREFIX_LENGTH)) {
代码示例来源:origin: apache/activemq-artemis
header = new Header();
header.setFirstAcquirer(message.getBooleanProperty(key));
continue;
} else if (key.equals(JMS_AMQP_HEADER)) {
代码示例来源:origin: org.apache.activemq/artemis-amqp-protocol
header = new Header();
header.setFirstAcquirer(message.getBooleanProperty(key));
continue;
} else if (key.equals(JMS_AMQP_HEADER)) {
代码示例来源:origin: org.apache.qpid/proton-j
break;
case 3:
header.setFirstAcquirer(decoder.readBoolean(null));
break;
case 4:
内容来源于网络,如有侵权,请联系作者删除!