Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Message-ID: <15934030.70981291295495060.JavaMail.jira@thor>
Date: Thu, 2 Dec 2010 08:11:35 -0500 (EST)
From: "Dejan Bosanac (JIRA)" <jira@apache.org>
To: dev@activemq.apache.org
Subject: [jira] Updated: (AMQ-2278) Unable to recevie BlobMessages from
 VmWare machine
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit


     [ https://issues.apache.org/jira/browse/AMQ-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dejan Bosanac updated AMQ-2278:
-------------------------------

    Fix Version/s:     (was: 5.4.2)
                   5.5.0

> Unable to recevie BlobMessages from VmWare machine
> --------------------------------------------------
>
>                 Key: AMQ-2278
>                 URL: https://issues.apache.org/jira/browse/AMQ-2278
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.2.0
>         Environment: ActiveMQ 5.2.0 with Jetty 6.1.18 embedded, running on SuSE Linux 9.1 (i586), using jdk 1.6.0_13 
>            Reporter: David Kjerrumgaard
>             Fix For: 5.5.0
>
>
> I have set up a small test client which sends files as ActiveMQ BlobMessages from any client machine to the ActiveMQ host machine (with Jetty embedded). Depending upon the platform of the CLIENT application I get the following errors in the activeMQ server log when attempting to send files to the fileserver application which comes with activeMQ:
> java.lang.IndexOutOfBoundsException: -58850
> at java.nio.DirectByteBuffer.get(DirectByteBuffer.java:209)
> at org.mortbay.io.nio.DirectNIOBuffer.peek(DirectNIOBuffer.java:97)
> at org.mortbay.io.ByteArrayBuffer.poke(ByteArrayBuffer.java:305)
> at org.mortbay.io.AbstractBuffer.put(AbstractBuffer.java:448)
> at org.mortbay.jetty.HttpParser.reset(HttpParser.java:948)
> at org.mortbay.jetty.HttpConnection.destroy(HttpConnection.java:151)
> at org.mortbay.jetty.AbstractConnector.connectionClosed(AbstractConnector.java:954)
> at org.mortbay.jetty.nio.SelectChannelConnector.access$100(SelectChannelConnector.java:64)
> at org.mortbay.jetty.nio.SelectChannelConnector$1.endPointClosed(SelectChannelConnector.java:92)
> at org.mortbay.io.nio.SelectChannelEndPoint.doUpdateKey(SelectChannelEndPoint.java:396)
> at org.mortbay.io.nio.SelectorManager$SelectSet.doSelect(SelectorManager.java:368)
> at org.mortbay.io.nio.SelectorManager.doSelect(SelectorManager.java:190)
> at org.mortbay.jetty.nio.SelectChannelConnector.accept(SelectChannelConnector.java:124)
> at org.mortbay.jetty.AbstractConnector$Acceptor.run(AbstractConnector.java:706)
> at org.mortbay.thread.QueuedThreadPool$PoolThread.run(QueuedThreadPool.java:520)
> The function which sends the BlobMessages is as follows:
> private void sendFile(String fileName) throws JMSException, IOException {
> 		
> 		System.out.println("Sending " + fileName + " to blob.test.queue" );
> 		
>                 // connection url is      "tcp://localhost:61616?jms.blobTransferPolicy.defaultUploadUrl=http://localhost.hdplus.com:8161/fileserver/"
> 		ActiveMQConnection connection = (ActiveMQConnection) factory.createConnection();
> 		connection.setCopyMessageOnSend(false);
>                connection.start();
>         
>         ActiveMQSession session = (ActiveMQSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
>         Destination destination = session.createQueue("blob.test.queue"); 
>                
>         File temp = File.createTempFile( FilenameUtils.getName(fileName), FilenameUtils.getExtension(fileName) );
>         temp.deleteOnExit();
>         FileUtils.copyFile(new File(fileName), temp );
>         
>         BlobMessage msg = session.createBlobMessage( temp );
>         MessageProducer producer = session.createProducer(destination); 
>         producer.send( msg );
>         
>         producer.close();
>         session.close();
>         connection.close();
>         
>         System.out.println("Published file " + fileName + " to " + destination.toString() );
> 	}
> I have also opened a ticket on the Jetty JIRA : (JETTY-1031) IndexOutOfBoundsException in fileserver application

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.