本文整理了Java中org.apache.activemq.command.Message.getProperties()
方法的一些代码示例,展示了Message.getProperties()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Message.getProperties()
方法的具体详情如下:
包路径:org.apache.activemq.command.Message
类名称:Message
方法名:getProperties
暂无
代码示例来源:origin: apache/activemq
@Override
public String toString(Map<String, Object>overrideFields) {
try {
getProperties();
} catch (IOException e) {
}
return super.toString(overrideFields);
}
代码示例来源:origin: apache/activemq
} else if (brokerStats) {
if (messageSend.getProperties().containsKey(STATS_BROKER_RESET_HEADER)) {
getBrokerView().resetStatistics();
代码示例来源:origin: org.apache.activemq/activemq-all
@Override
public String toString(Map<String, Object>overrideFields) {
try {
getProperties();
} catch (IOException e) {
}
return super.toString(overrideFields);
}
代码示例来源:origin: org.apache.activemq/activemq-client
@Override
public String toString(Map<String, Object>overrideFields) {
try {
getProperties();
} catch (IOException e) {
}
return super.toString(overrideFields);
}
代码示例来源:origin: org.apache.activemq/activemq-osgi
@Override
public String toString(Map<String, Object>overrideFields) {
try {
getProperties();
} catch (IOException e) {
}
return super.toString(overrideFields);
}
代码示例来源:origin: pierre/meteo
@Override
public String toString(Map<String, Object>overrideFields) {
try {
getProperties();
} catch (IOException e) {
}
return super.toString(overrideFields);
}
}
代码示例来源:origin: apache/activemq-artemis
private static void putMsgMarshalledProperties(final ByteSequence propBytes,
final Message messageSend,
final CoreMessage coreMessage) throws IOException {
propBytes.compact();
coreMessage.putBytesProperty(AMQ_MSG_MARSHALL_PROP, propBytes.data);
//unmarshall properties to core so selector will work
final Map<String, Object> props = messageSend.getProperties();
if (!props.isEmpty()) {
props.forEach((key, value) -> {
try {
coreMessage.putObjectProperty(key, value);
} catch (ActiveMQPropertyConversionException e) {
coreMessage.putStringProperty(key, value.toString());
}
});
}
}
代码示例来源:origin: apache/activemq-artemis
if (connection.getContext().isFaultTolerant() && !messageSend.getProperties().containsKey(org.apache.activemq.artemis.api.core.Message.HDR_DUPLICATE_DETECTION_ID.toString())) {
originalCoreMsg.putStringProperty(org.apache.activemq.artemis.api.core.Message.HDR_DUPLICATE_DETECTION_ID, SimpleString.toSimpleString(messageSend.getMessageId().toString()));
代码示例来源:origin: org.apache.activemq/activemq-osgi
} else if (brokerStats) {
if (messageSend.getProperties().containsKey(STATS_BROKER_RESET_HEADER)) {
getBrokerView().resetStatistics();
代码示例来源:origin: org.apache.activemq/activemq-broker
} else if (brokerStats) {
if (messageSend.getProperties().containsKey(STATS_BROKER_RESET_HEADER)) {
getBrokerView().resetStatistics();
代码示例来源:origin: org.apache.activemq/activemq-all
} else if (brokerStats) {
if (messageSend.getProperties().containsKey(STATS_BROKER_RESET_HEADER)) {
getBrokerView().resetStatistics();
内容来源于网络,如有侵权,请联系作者删除!