Package org.apache.activemq.command

Examples of org.apache.activemq.command.ActiveMQBlobMessage

50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
        writer.close();

        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(URI);
        BlobTransferPolicy policy = factory.getBlobTransferPolicy();

        ActiveMQBlobMessage msg = new ActiveMQBlobMessage();
        msg.setMessageId(new MessageId());

        // 1. Upload
        DefaultBlobUploadStrategy strategy = new DefaultBlobUploadStrategy(policy);
        strategy.uploadFile(msg, file);

        // 2. Download
        msg.setURL(new URL(FILESERVER_URL + msg.getMessageId()));

        InputStream in = msg.getInputStream();
        long bytesRead = 0;
        byte[] buffer = new byte[1024 * 1024];

        while (true) {
            int c = in.read(buffer);
View Full Code Here
125
126
127
128
129
130
131
132
133
134
        writer.close();
       
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        ((ActiveMQConnection)connection).setCopyMessageOnSend(false);
       
        ActiveMQBlobMessage message = (ActiveMQBlobMessage) ((ActiveMQSession)session).createBlobMessage(file);
        message.setMessageId(new MessageId("testmessage"));
        message.onSend();
        Assert.assertEquals(ftpUrl + "testmessage", message.getURL().toString());
  }
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
        wrt.close();

    }

    public void testDownload() {
        ActiveMQBlobMessage message = new ActiveMQBlobMessage();
        BlobDownloadStrategy strategy = new FTPBlobDownloadStrategy();
        InputStream stream;
        try {
            message.setURL(new URL(ftpUrl + "test.txt"));
            stream = strategy.getInputStream(message);
            int i = stream.read();
            StringBuilder sb = new StringBuilder(2048);
            while(i != -1) {
                sb.append((char)i);
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
122
123
124
            Assert.assertTrue(false);
        }
    }

    public void testWrongAuthentification() {
        ActiveMQBlobMessage message = new ActiveMQBlobMessage();
        BlobDownloadStrategy strategy = new FTPBlobDownloadStrategy();
        try {
            message.setURL(new URL("ftp://" + userNamePass + "_wrong:" + userNamePass + "@localhost:"  + ftpPort + "/ftptest/"));
            strategy.getInputStream(message);
        } catch(JMSException e) {
            Assert.assertEquals("Wrong Exception", "Cant Authentificate to FTP-Server", e.getMessage());
            return;
        } catch(Exception e) {
View Full Code Here
129
130
131
132
133
134
135
136
137
138
139
140
141
142
        Assert.assertTrue("Expect Exception", false);
    }

    public void testWrongFTPPort() {
        ActiveMQBlobMessage message = new ActiveMQBlobMessage();
        BlobDownloadStrategy strategy = new FTPBlobDownloadStrategy();
        try {
            message.setURL(new URL("ftp://" + userNamePass + ":" + userNamePass + "@localhost:"  + 422 + "/ftptest/"));
            strategy.getInputStream(message);
        } catch(JMSException e) {
            Assert.assertEquals("Wrong Exception", "Problem connecting the FTP-server", e.getMessage());
            return;
        } catch(Exception e) {
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
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.