如果使用HornetQ的核心，ClientSessionFactory.setMinLargeMessageSize方法 可以设置大消息的最小值。

ClientSessionFactory factory = 
            HornetQClient.createClientSessionFactory(new 
            TransportConfiguration(NettyConnectorFactory.class.getName()), null);
factory.setMinLargeMessageSize(25 * 1024);

Section 16.3, “在客户端直接配置传输层”对于如何实例化一个会话工厂（session factory） 给出了进一步的说明。

如果连接工厂是通过JNDI方式获得的，则需要在hornetq-jms.xml文件中定义：

...
<connection-factory name="ConnectionFactory">
<connectors>
   <connector-ref connector-name="netty"/>
</connectors>
<entries>
   <entry name="ConnectionFactory"/>
   <entry name="XAConnectionFactory"/>
</entries>
                
<min-large-message-size>250000</min-large-message-size>
</connection-factory>
...

如果是直接实例化连接工厂，则使用HornetQConnectionFactory.setMinLargeMessageSize方法来定义。

下表列出了ClientMessage上可以使用的方法。 通过相应的对象属性也可以在JMS中应用。

下面代码中设定了接收核心消息所用的输出流：

...
ClientMessage msg = consumer.receive(...);


// This will block here until the stream was transferred
msg.saveOutputStream(someOutputStream); 

ClientMessage msg2 = consumer.receive(...);

// This will not wait the transfer to finish
msg.setOutputStream(someOtherOutputStream); 
...
                
            

设定发送核心消息所用的输入流：

...
ClientMessage msg = session.createMessage();
msg.setInputStream(dataInputStream);
...
            

使用JMS时，HornetQ根据定义的属性值调用对应的核心接口（参见 Table 23.1, “org.hornetq.api.core.client.ClientMessage API”）来使用流。你只需要用 Message.setObjectProperty方法设置适当的输入／输出流即可。

输入流InputStream可以通过JMS属性JMS_HQ_InputStream来定义：

BytesMessage message = session.createBytesMessage();

FileInputStream fileInputStream = new FileInputStream(fileInput);

BufferedInputStream bufferedInput = new BufferedInputStream(fileInputStream);

message.setObjectProperty("JMS_HQ_InputStream", bufferedInput);

someProducer.send(message);

输出流OutputStream可以通过JMS属性JMS_HQ_SaveStream来定义。下面是阻塞式方法：

BytesMessage messageReceived = (BytesMessage)messageConsumer.receive(120000);
                
File outputFile = new File("huge_message_received.dat");
                
FileOutputStream fileOutputStream = new FileOutputStream(outputFile);
                
BufferedOutputStream bufferedOutput = new BufferedOutputStream(fileOutputStream);
                
// This will block until the entire content is saved on disk
messageReceived.setObjectProperty("JMS_HQ_SaveStream", bufferedOutput);
            

也可以使用JMS_HQ_OutputStream属性以非阻塞式（异步）方法来定义输出流OutputStream：

// This won't wait the stream to finish. You need to keep the consumer active.
messageReceived.setObjectProperty("JMS_HQ_OutputStream", bufferedOutput);