org.apache.qpid.proton.amqp.Binary.toString()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(2.5k)|赞(0)|评价(0)|浏览(136)

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

Binary.toString介绍

暂无

代码示例

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

  1. @Override
  2. public String toString() {
  3. return data.toString();
  4. }
  5. }

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

  1. @Override
  2. public String toString() {
  3. return data.toString();
  4. }
  5. }

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

  1. @Override
  2. public String toString()
  3. {
  4. return data.toString();
  5. }
  6. }

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

  1. public Transaction getTransaction(Binary txid, boolean remove) throws ActiveMQAMQPException {
  2. Transaction tx;
  3. if (remove) {
  4. tx = transactions.remove(txid);
  5. } else {
  6. tx = transactions.get(txid);
  7. }
  8. if (tx == null) {
  9. logger.warn("Couldn't find txid = " + txid);
  10. throw ActiveMQAMQPProtocolMessageBundle.BUNDLE.txNotFound(txid.toString());
  11. }
  12. return tx;
  13. }

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

  1. public Transaction getTransaction(Binary txid, boolean remove) throws ActiveMQAMQPException {
  2. Transaction tx;
  3. if (remove) {
  4. tx = transactions.remove(txid);
  5. } else {
  6. tx = transactions.get(txid);
  7. }
  8. if (tx == null) {
  9. logger.warn("Couldn't find txid = " + txid);
  10. throw ActiveMQAMQPProtocolMessageBundle.BUNDLE.txNotFound(txid.toString());
  11. }
  12. return tx;
  13. }

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

  1. static void log(Object ctx, String event, TransportFrame frame)
  2. {
  3. if (ENABLED) {
  4. StringBuilder msg = new StringBuilder();
  5. msg.append("[").append(System.identityHashCode(ctx)).append(":")
  6. .append(frame.getChannel()).append("]");
  7. msg.append(" ").append(event).append(" ").append(frame.getBody());
  8. if (frame.getPayload() != null) {
  9. String payload = frame.getPayload().toString();
  10. if (payload.length() > 80) {
  11. payload = payload.substring(0, 80) + "(" + payload.length() + ")";
  12. }
  13. msg.append(" \"").append(payload).append("\"");
  14. }
  15. System.out.println(msg.toString());
  16. }
  17. }

代码示例来源:origin: eclipse/hono

  1. private void handleMessage(final String msgType, final Message msg) {
  2. final Data body = (Data) msg.getBody();
  3. LOG.debug("Type: [{}] and Message: [{}]", msgType, body != null ? body.getValue().toString() : "");
  4. }

代码示例来源:origin: Azure/azure-iot-sdk-java

  1. iotHubTransportMessage.setProperty(AMQPS_APP_PROPERTY_PREFIX + USER_ID_KEY, properties.getUserId().toString());

代码示例来源:origin: Azure/azure-iot-sdk-java

  1. amqpFeedbackReceivedEvent.onFeedbackReceived(feedbackJson.getValue().toString());

相关文章