inchlin wrote: > > Hi all: > > I try to consume compressed message use spring container > But I can't make the the message compressed > How do I make it? > Thanks in advise! > > This is my sample code to start the consumer > > ActiveMQConnectionFactory connectionFactory = new > ActiveMQConnectionFactory(); > connectionFactory.setBrokerURL(url); > connectionFactory.setUseCompression(true); > > container = new DefaultMessageListenerContainer(); > container.setConnectionFactory(connectionFactory); > container.setMessageListener(this); > container.setDestinationName(subject); > container.setSessionTransacted(transacted); > container.setMessageListener(this); > container.setSubscriptionDurable(true); > container.afterPropertiesSet(); > > You need to set the compression on the producer. James -- View this message in context: http://www.nabble.com/How-to-compress-payload-in-spring-container--tf3031651.html#a8435649 Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
