本文整理了Java中org.apache.qpid.proton.amqp.Binary.toString()
方法的一些代码示例,展示了Binary.toString()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Binary.toString()
方法的具体详情如下:
包路径:org.apache.qpid.proton.amqp.Binary
类名称:Binary
方法名:toString
暂无
代码示例来源:origin: org.apache.activemq/activemq-osgi
@Override
public String toString() {
return data.toString();
}
}
代码示例来源:origin: org.apache.activemq/activemq-all
@Override
public String toString() {
return data.toString();
}
}
代码示例来源:origin: org.apache.qpid/proton-jms
@Override
public String toString()
{
return data.toString();
}
}
代码示例来源:origin: org.apache.activemq/artemis-amqp-protocol
public Transaction getTransaction(Binary txid, boolean remove) throws ActiveMQAMQPException {
Transaction tx;
if (remove) {
tx = transactions.remove(txid);
} else {
tx = transactions.get(txid);
}
if (tx == null) {
logger.warn("Couldn't find txid = " + txid);
throw ActiveMQAMQPProtocolMessageBundle.BUNDLE.txNotFound(txid.toString());
}
return tx;
}
代码示例来源:origin: apache/activemq-artemis
public Transaction getTransaction(Binary txid, boolean remove) throws ActiveMQAMQPException {
Transaction tx;
if (remove) {
tx = transactions.remove(txid);
} else {
tx = transactions.get(txid);
}
if (tx == null) {
logger.warn("Couldn't find txid = " + txid);
throw ActiveMQAMQPProtocolMessageBundle.BUNDLE.txNotFound(txid.toString());
}
return tx;
}
代码示例来源:origin: org.apache.qpid/proton-j-impl
static void log(Object ctx, String event, TransportFrame frame)
{
if (ENABLED) {
StringBuilder msg = new StringBuilder();
msg.append("[").append(System.identityHashCode(ctx)).append(":")
.append(frame.getChannel()).append("]");
msg.append(" ").append(event).append(" ").append(frame.getBody());
if (frame.getPayload() != null) {
String payload = frame.getPayload().toString();
if (payload.length() > 80) {
payload = payload.substring(0, 80) + "(" + payload.length() + ")";
}
msg.append(" \"").append(payload).append("\"");
}
System.out.println(msg.toString());
}
}
代码示例来源:origin: eclipse/hono
private void handleMessage(final String msgType, final Message msg) {
final Data body = (Data) msg.getBody();
LOG.debug("Type: [{}] and Message: [{}]", msgType, body != null ? body.getValue().toString() : "");
}
代码示例来源:origin: Azure/azure-iot-sdk-java
iotHubTransportMessage.setProperty(AMQPS_APP_PROPERTY_PREFIX + USER_ID_KEY, properties.getUserId().toString());
代码示例来源:origin: Azure/azure-iot-sdk-java
amqpFeedbackReceivedEvent.onFeedbackReceived(feedbackJson.getValue().toString());
内容来源于网络,如有侵权,请联系作者删除!