Package org.apache.qpid.amqp_1_0.type

Examples of org.apache.qpid.amqp_1_0.type.Binary

76
77
78
79
80
81
82
83
84
85
86
            {
                _header[_received++] = buf.get();
            }
            if(_received == 8)
            {
                Binary header = new Binary(_header);
                _delegate = _headersMap.get(header);
                if(_delegate != null)
                {
                    _delegate.processBytes(ByteBuffer.wrap(_header));
                    _delegate.processBytes(buf);
View Full Code Here
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
        }

        ByteBuffer inDup = in.slice();
        inDup.limit(inDup.position()+size);

        Binary binary;
/*        if(isCopy && inDup.hasArray())
        {
            binary= new Binary(inDup.array(), inDup.arrayOffset()+inDup.position(),size);
        }
        else
        {*/
            byte[] buf = new byte[size];
            inDup.get(buf);
            binary = new Binary(buf);
  /*      }*/

        in.position(in.position()+size);


View Full Code Here
323
324
325
326
327
328
329
    private Object generateMessageId()
    {
        UUID uuid = UUID.randomUUID();
        final String messageIdString = uuid.toString();
        return _session.getConnection().useBinaryMessageId() ? new Binary(messageIdString.getBytes()) : messageIdString;
    }
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
                                                (String) ((AmqpValue)bodySection).getValue(), footer, _session);
            }
            else if(bodySection instanceof AmqpValue && ((AmqpValue)bodySection).getValue() instanceof Binary)
            {

                Binary value = (Binary) ((AmqpValue) bodySection).getValue();
                message = new BytesMessageImpl(header, messageAnnotations, properties, appProperties,
                                               new Data(value), footer, _session);
            }
            else if(bodySection instanceof Data)
            {
View Full Code Here
93
94
95
96
97
98
99
100
101
102
103
            ObjectOutputStream oos = new ObjectOutputStream(baos);
            oos.writeObject(serializable);
            oos.flush();
            oos.close();

            _objectData = new Data(new Binary(baos.toByteArray()));

        }
        catch (IOException e)
        {
            e.printStackTrace();  //TODO
View Full Code Here
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
        if(_objectData == null)
        {
            return null;
        }

        Binary data = _objectData.getValue();

        try
        {
            ObjectInputStream ois = new ObjectInputStream(new ByteArrayInputStream(data.getArray(), data.getArrayOffset(), data.getLength()));
            return (Serializable) ois.readObject();
        }
        catch (IOException e)
        {
            JMSException jmsException = new JMSException(e.getMessage());
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121

            Sender s = session.createSender(queue, 10);

            Message message = new Message("dump me");
            message.setDeliveryTag(new Binary("dump".getBytes()));

            s.send(message);

            s.close();
            session.close();
View Full Code Here
366
367
368
369
370
371
372
        {
            val = new byte[length];
            System.arraycopy(bytes,offset,val,0,length);
        }

        put(name, new Binary(val));
    }
View Full Code Here
166
167
168
169
170
171
172
173
174
175
176
                            System.arraycopy(origBytes,0,bytes,0,origBytes.length);
                            for(int x = origBytes.length; x < bytes.length; x++)
                            {
                                bytes[x] = (byte) '.';
                            }
                            bodySection = new Data(new Binary(bytes));
                        }
                        else
                        {
                            bodySection = new AmqpValue(message + " " + i);
                        }
View Full Code Here
139
140
141
142
143
144
145
146
147
148
149
                for(String fileName : unsettledFiles)
                {
                    File aFile = new File(tmpDirectory, fileName);
                    if(aFile.canRead() && aFile.canWrite())
                    {
                        Binary deliveryTag = new Binary(md5.digest(fileName.getBytes()));
                        unsettled.put(deliveryTag, null);
                        unsettledFileNames.put(deliveryTag, fileName);
                    }
                }
View Full Code Here
TOP

Related Classes of org.apache.qpid.amqp_1_0.type.Binary

  • org.apache.activemq.karaf.itest.ActiveMQAMQPBrokerFeatureTest
  • org.apache.activemq.transport.amqp.AMQ4563Test
  • org.apache.activemq.transport.amqp.AMQ4696Test
  • org.apache.activemq.transport.amqp.AMQ4920Test
  • org.apache.activemq.transport.amqp.AMQ4930ConsumerTask
  • org.apache.activemq.transport.amqp.AmqpTransformerTest
  • org.apache.activemq.transport.amqp.bugs.AMQ4753Test
  • org.apache.activemq.transport.amqp.bugs.AMQ4914Test
  • org.apache.activemq.transport.amqp.JmsClientRequestResponseTest
  • org.apache.activemq.transport.amqp.JMSClientTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.