Package org.apache.activemq.command

Examples of org.apache.activemq.command.ActiveMQBlobMessage

488
489
490
491
492
493
494
495
496
497
498
499
500
     * @return a BlobMessage
     * @throws JMSException if the JMS provider fails to create this message due
     *                 to some internal error.
     */
    public BlobMessage createBlobMessage(File file) throws JMSException {
        ActiveMQBlobMessage message = new ActiveMQBlobMessage();
        configureMessage(message);
        message.setBlobUploader(new BlobUploader(getBlobTransferPolicy(), file));
        message.setBlobDownloader(new BlobDownloader((getBlobTransferPolicy())));
        message.setDeletedByBroker(true);
        message.setName(file.getName());
        return message;
    }
View Full Code Here
511
512
513
514
515
516
517
518
519
520
521
522
     * @return a BlobMessage
     * @throws JMSException if the JMS provider fails to create this message due
     *                 to some internal error.
     */
    public BlobMessage createBlobMessage(InputStream in) throws JMSException {
        ActiveMQBlobMessage message = new ActiveMQBlobMessage();
        configureMessage(message);
        message.setBlobUploader(new BlobUploader(getBlobTransferPolicy(), in));
        message.setBlobDownloader(new BlobDownloader(getBlobTransferPolicy()));
        message.setDeletedByBroker(true);
        return message;
    }
View Full Code Here
450
451
452
453
454
455
456
457
458
459
460
461
462
463
            addItem(CompositeDataConstants.MESSAGE_URL, "Body Url", SimpleType.STRING);
        }

        @Override
        public Map<String, Object> getFields(Object o) throws OpenDataException {
            ActiveMQBlobMessage m = (ActiveMQBlobMessage)o;
            Map<String, Object> rc = super.getFields(o);
            try {
                rc.put(CompositeDataConstants.MESSAGE_URL, "" + m.getURL().toString());
            } catch (JMSException e) {
                rc.put(CompositeDataConstants.MESSAGE_URL, "");
            }
            return rc;
        }
View Full Code Here
51
52
53
54
55
56
57
   
    /**
     * @return a new object instance
     */
    public DataStructure createObject() {
        return new ActiveMQBlobMessage();
    }
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
     * @throws IOException
     */
    public void tightUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn, BooleanStream bs) throws IOException {
        super.tightUnmarshal(wireFormat, o, dataIn, bs);

        ActiveMQBlobMessage info = (ActiveMQBlobMessage)o;
        info.setRemoteBlobUrl(tightUnmarshalString(dataIn, bs));
        info.setMimeType(tightUnmarshalString(dataIn, bs));
        info.setDeletedByBroker(bs.readBoolean());

    }
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
88
89
90
    /**
     * Write the booleans that this object uses to a BooleanStream
     */
    public int tightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) throws IOException {

        ActiveMQBlobMessage info = (ActiveMQBlobMessage)o;

        int rc = super.tightMarshal1(wireFormat, o, bs);
        rc += tightMarshalString1(info.getRemoteBlobUrl(), bs);
        rc += tightMarshalString1(info.getMimeType(), bs);
        bs.writeBoolean(info.isDeletedByBroker());

        return rc + 0;
    }
View Full Code Here
97
98
99
100
101
102
103
104
105
106
107
     * @throws IOException thrown if an error occurs
     */
    public void tightMarshal2(OpenWireFormat wireFormat, Object o, DataOutput dataOut, BooleanStream bs) throws IOException {
        super.tightMarshal2(wireFormat, o, dataOut, bs);

        ActiveMQBlobMessage info = (ActiveMQBlobMessage)o;
        tightMarshalString2(info.getRemoteBlobUrl(), dataOut, bs);
        tightMarshalString2(info.getMimeType(), dataOut, bs);
        bs.readBoolean();

    }
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
     * @throws IOException
     */
    public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException {
        super.looseUnmarshal(wireFormat, o, dataIn);

        ActiveMQBlobMessage info = (ActiveMQBlobMessage)o;
        info.setRemoteBlobUrl(looseUnmarshalString(dataIn));
        info.setMimeType(looseUnmarshalString(dataIn));
        info.setDeletedByBroker(dataIn.readBoolean());

    }
View Full Code Here
127
128
129
130
131
132
133
134
135
136
137
138
139
    /**
     * Write the booleans that this object uses to a BooleanStream
     */
    public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException {

        ActiveMQBlobMessage info = (ActiveMQBlobMessage)o;

        super.looseMarshal(wireFormat, o, dataOut);
        looseMarshalString(info.getRemoteBlobUrl(), dataOut);
        looseMarshalString(info.getMimeType(), dataOut);
        dataOut.writeBoolean(info.isDeletedByBroker());

    }
View Full Code Here
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
                msg.setConnection(connection);
                msg.setText(textMsg.getText());
                activeMessage = msg;
            } else if (message instanceof BlobMessage) {
              BlobMessage blobMessage = (BlobMessage)message;
              ActiveMQBlobMessage msg = new ActiveMQBlobMessage();
              msg.setConnection(connection);
              msg.setBlobDownloader(new BlobDownloader(connection.getBlobTransferPolicy()));
              try {
          msg.setURL(blobMessage.getURL());
        } catch (MalformedURLException e) {
         
        }
              activeMessage = msg;
            } else {
View Full Code Here
TOP

Related Classes of org.apache.activemq.command.ActiveMQBlobMessage

  • org.apache.activemq.ActiveMQMessageTransformation
  • org.apache.activemq.ActiveMQSession
  • org.apache.activemq.blob.DefaultBlobUploadStrategyTest
  • org.apache.activemq.blob.FTPBlobDownloadStrategyTest
  • org.apache.activemq.blob.FTPBlobUploadStrategyTest
  • org.apache.activemq.broker.jmx.OpenTypeSupport$ActiveMQBlobMessageOpenTypeFactory
  • org.apache.activemq.console.command.store.amq.MessageBodyFormatter
  • org.apache.activemq.openwire.v3.ActiveMQBlobMessageMarshaller
  • org.apache.activemq.store.amq.MessageBodyFormatter
  • org.apache.camel.component.jms.JmsBindingTest
    • 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.