Hi, seems like a missing jetty dependency. Will take a look at it.
Cheers -- Dejan Bosanac - http://twitter.com/dejanb Open Source Integration - http://fusesource.com/ ActiveMQ in Action - http://www.manning.com/snyder/ Blog - http://www.nighttale.net On Wed, Mar 24, 2010 at 1:19 PM, rauch <kozyn...@gmail.com> wrote: > > OS: ubuntu-9.10-amd64 > java version "1.6.0_15" > Java(TM) SE Runtime Environment (build 1.6.0_15-b03) > Java HotSpot(TM) 64-Bit Server VM (build 14.1-b02, mixed mode) > > ------------------------------------------------------------------------------------------------------------------- > When I use apache-activemq-5.3.0-bin I can create Producer and can send > BlobMessages using > "tcp://localhost:61616?jms.blobTransferPolicy.defaultUploadUrl= > http://localhost:8161/fileserver/"; > But in 5.3.0 all BlobMessages (Files) are hold at > ~/apache-activemq-5.3.0/webapps/fileserver/ directory all time. > (JMSDeliveryMode = Non-Persistent, JMSExpiration = 10000L, Non-Durable > Subscription) even this File was delivered to all subscribers. > > ----------------------------------------------------------------------------------------------------------------- > Ok, by now I decide using apache-activemq-5.4-SNAPSHOT-bin. I rebuild my > java project with new library and what a have: > I start apache-activemq-5.4-SNAPSHOT/bin/activemq with default configs. > Now, I can send TextMessages to Topic and All subscribers get it. But when > I > send BlobMessages to Topic I get an Exception: at clients side: > sendFile Exception java.lang.Exception: javax.jms.JMSException: PUT was not > successful: 500 org/eclipse/jetty/util/URIUtil java.lang.Exception: > javax.jms.JMSException: PUT was not successful: 500 > org/eclipse/jetty/util/URIUtil at > activemqmessaging.ProducerTool.sendBLOBMessage(ProducerTool.java:137) at > n_sserver.Server.sendFile(Server.java:52) at > n_sserver.Server.startServer(Server.java:82) at > n_sserver.Server.main(Server.java:122) Caused by: javax.jms.JMSException: > PUT was not successful: 500 org/eclipse/jetty/util/URIUtil at > > org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62) > at > > org.apache.activemq.command.ActiveMQBlobMessage.onSend(ActiveMQBlobMessage.java:176) > at org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1732) at > > org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:231) > at > > org.apache.activemq.ActiveMQMessageProducerSupport.send(ActiveMQMessageProducerSupport.java:241) > at activemqmessaging.ProducerTool.sendBLOBMessage(ProducerTool.java:119) > ... 3 more Caused by: java.io.IOException: PUT was not successful: 500 > org/eclipse/jetty/util/URIUtil at > > org.apache.activemq.blob.DefaultBlobUploadStrategy.uploadStream(DefaultBlobUploadStrategy.java:70) > at > > org.apache.activemq.blob.DefaultBlobUploadStrategy.uploadFile(DefaultBlobUploadStrategy.java:44) > at org.apache.activemq.blob.BlobUploader.upload(BlobUploader.java:51) at > > org.apache.activemq.command.ActiveMQBlobMessage.onSend(ActiveMQBlobMessage.java:173) > ... 7 more > =========================================================== > At Broker`s log I get: > Loading message broker from: xbean:activemq.xml > INFO | > > PListStore:/home/rauch/Downloads/Programs/Different/ActiveMQ/apache-activemq-5.4-SNAPSHOT/data/activemqBroker5.4/tmp_storage > started > INFO | Using Persistence Adapter: > org.apache.activemq.store.kahadb.kahadbpersistenceadap...@710ca208 > INFO | Replayed 1 operations from the journal in 0.01 seconds. > INFO | ActiveMQ 5.4-SNAPSHOT JMS Message Broker (activemqBroker5.4) is > starting > INFO | For help or more information please see: > http://activemq.apache.org/ > INFO | Scheduler using directory: activemq-data/scheduler > INFO | Listening for connections at: tcp://rauch-laptop:61616 > INFO | Connector openwire Started > INFO | ActiveMQ JMS Message Broker (activemqBroker5.4, > ID:rauch-laptop-46943-1269431686418-0:0) started > INFO | Logging to > org.slf4j.impl.JCLLoggerAdapter(org.eclipse.jetty.util.log) via > org.eclipse.jetty.util.log.Slf4jLog > INFO | jetty-7.0.1.v20091125 > INFO | ActiveMQ WebConsole initialized. > INFO | Initializing Spring FrameworkServlet 'dispatcher' > INFO | ActiveMQ Console at http://0.0.0.0:8161/admin > INFO | Initializing Spring root WebApplicationContext > INFO | Successfully connected to tcp://localhost:61616 > INFO | Camel Console at http://0.0.0.0:8161/camel > INFO | ActiveMQ Web Demos at http://0.0.0.0:8161/demo > INFO | RESTful file access application at http://0.0.0.0:8161/fileserver > INFO | Started selectchannelconnec...@0.0.0.0:8161 > ERROR | Error for /fileserver/ID:rauch-laptop-35835-1269431710986-0:2:1:1:1 > java.lang.NoClassDefFoundError: org/eclipse/jetty/util/URIUtil > at > org.apache.activemq.util.RestFilter.locateFile(RestFilter.java:74) > at org.apache.activemq.util.RestFilter.doPut(RestFilter.java:163) > at org.apache.activemq.util.RestFilter.doFilter(RestFilter.java:92) > at > > org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1187) > at > > org.apache.activemq.util.FilenameGuardFilter.doFilter(FilenameGuardFilter.java:50) > at > > org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1187) > at > org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:425) > at > > org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:119) > at > org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:494) > at > > org.eclipse.jetty.server.session.SessionHandler.handle(SessionHandler.java:182) > at > > org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:933) > at > org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:362) > at > > org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:867) > at > > org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:117) > at > > org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:126) > at > > org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:113) > at org.eclipse.jetty.server.Server.handle(Server.java:334) > at > > org.eclipse.jetty.server.HttpConnection.handleRequest(HttpConnection.java:559) > at > > org.eclipse.jetty.server.HttpConnection$RequestHandler.content(HttpConnection.java:1007) > at org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:839) > at > org.eclipse.jetty.http.HttpParser.parseAvailable(HttpParser.java:209) > at > org.eclipse.jetty.server.HttpConnection.handle(HttpConnection.java:406) > at > > org.eclipse.jetty.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:462) > at > > org.eclipse.jetty.util.thread.QueuedThreadPool$2.run(QueuedThreadPool.java:436) > at java.lang.Thread.run(Thread.java:619) > Caused by: java.lang.ClassNotFoundException: org.eclipse.jetty.util.URIUtil > at java.net.URLClassLoader$1.run(URLClassLoader.java:200) > at java.security.AccessController.doPrivileged(Native Method) > at java.net.URLClassLoader.findClass(URLClassLoader.java:188) > at > > org.eclipse.jetty.webapp.WebAppClassLoader.loadClass(WebAppClassLoader.java:304) > at > > org.eclipse.jetty.webapp.WebAppClassLoader.loadClass(WebAppClassLoader.java:266) > at java.lang.ClassLoader.loadClassInternal(ClassLoader.java:320) > ... 25 more > ============================================================== > What do I need to change that I can send BlobMessages? > this.producer = new > > ProducerTool.Builder("tcp://localhost:61616?jms.blobTransferPolicy.defaultUploadUrl= > http://localhost:8161/fileserver/";, > "ServerProdTopic").topic(true) > .transacted(false).durable(false).timeToLive(0).build(); > > //some code here > connection = createConnection(); > session = createSession(connection); > producer = createProducer(session); > producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); > BlobMessage blobMsg = ((ActiveMQSession) > session).createBlobMessage(resource); > > producer.send(blobMsg); > > > ----------------------------------------------------------------------------------------------------------------- > Where > protected MessageProducer createProducer(Session session) throws > JMSException { > MessageProducer producer = session.createProducer(destination); > producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); > System.out.println("DeliveryMode: "+producer.getDeliveryMode()); > if (timeToLive != 0) > producer.setTimeToLive(timeToLive); > return producer; > } > And > protected Connection createConnection() throws JMSException, Exception { > ActiveMQConnectionFactory connectionFactory = new > ActiveMQConnectionFactory(url); > > //connectionFactory.getBlobTransferPolicy().setUploadUrl(" > http://localhost:8161/fileserver/";); > Connection connection = connectionFactory.createConnection(); > if (durable && clientID != null) { > connection.setClientID(clientID); > } > connection.start(); > ((ActiveMQConnection) connection).setCopyMessageOnSend(false); > return connection; > } > -- > View this message in context: > http://old.nabble.com/BlobMessage%2C-5.3.0-Valid%2C-5.4.0%28Snapshot%29-exception-tp28014259p28014259.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > >
