LMS Samples

Sending a large message

CODE

//create the large message
TextMessage lmsg = session.createTextMessage();
lmsg.setStringProperty("JMSX_LM_PATH", "D:\\batch\\lms_samples
send.zip");
//register status listener
((ILargeMessage) lmsg).setLMStatusListener(new TrackStatus());
//start the message transfer
msgProducer.send(lmsg);

Receiving a large message

CODE

//receive the normal JMS message containing a reference to the large message
ILargeMessage lmsg = (ILargeMessage) qReceiver.receive();
//register status listener
lmsg.setLMStatusListener(new TrackStatus());
//start the message transfer
lmsg.saveTo("received.zip");

Resuming a message transfer on the send side

CODE

Enumeration enum =
((ILMConnection)jmsConnection).getUnfinishedMessagesToSend ();
while(enum.hasMoreElements())
{
//get the reference for the large unfinished message 
ILargeMessage lmsg = (ILargeMessage)enum.nextElement();
//register status listener
lmsg.setLMStatusListener(new TrackStatus());
//resume the transfer
lmsg.resumeSend(); ;
}

Resuming a message transfer on the receive side

CODE

Enumeration enum =
((ILMConnection)jmsConnection).getUnfinishedMessagesToReceive ();
while(enum.hasMoreElements())
{
//recreate the large message
ILargeMessage lmsg = (ILargeMessage)umEnum.nextElement();
//registering status listener
lmsg.setLMStatusListener(new TrackStatus());
//resume the transfer
lmsg.resumeSaveTo ();
}

The time duration that the receiver waits till resuming the interrupted message transfer can be configured through the Wait period in the parameter 'ResumeTimeoutInterval'. By default, this time duration is 15 seconds.

To set the resume timeout interval, perform the following steps:

Launch Fiorano eStudio and open the Profile Manager. Right-click the Profiles node and select Open Profile from the pop-up menu. Select the desired profile for editing in the offline mode and click on the Open button.
In the Profile Manager pane navigate to FioranoMQ > Fiorano > etc > FMQConfigLoader.
In the properties pane, set the value for the Resumetimeoutinterval property.
After making the above change, right-click the FioranoMQ domain in the Profile Manager and select the Save option from the pop-up menu.