MQSeries.net :: View topic - start file transfer by putting message in the command queue

boristep · Posted: Sat Apr 05, 2014 1:27 am Post subject:

According to InfoCenter it's possible start a file transfer by putting a file transfer message on the command queue of the source agent. For example SYSTEM.FTE.COMMAND.AGENT01
There is a sample program:

public class MQSample {

// code identifier
static final String sccsid = "@(#) samples/wmqjava/MQSample.java, jmscc.samples, k701, k701-110-130204 1.8.1.1 09/08/17 07:42:55";

// define the name of the QueueManager
private static final String qManager = "QMA";
// and define the name of the Queue
private static final String qName = "SYSTEM.FTE.COMMAND.AGENTA";

public static void main(String args[]) {
try {
// Create a connection to the QueueManager
System.out.println("Connecting to queue manager: " + qManager);
MQQueueManager qMgr = new MQQueueManager(qManager);

// Set up the options on the queue we wish to open

int openOptions = MQConstants.MQOO_OUTPUT;
// Now specify the queue that we wish to open and the open options
System.out.println("Accessing queue: " + qName);
MQQueue queue = qMgr.accessQueue(qName, openOptions);

// Define a simple WebSphere MQ Message ...
MQMessage msg = new MQMessage();
// ... and write some text in UTF8 format

String s = new String(" <?xml version=\"1.0\" encoding=\"UTF-8\"?><request version=\"4.00\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xsi:noNamespaceSchemaLocation=\"FileTransfer.xsd\">\n"+
"<managedTransfer>\n"+
"<originator>\n"+
"<hostName>10.0.0.6</hostName>\n"+
"<userID>BorisT</userID>\n"+
"</originator>\n"+
"<sourceAgent QMgr=\"QMA\" agent=\"AGENTA\"/>\n"+
"<destinationAgent QMgr=\"QMB\" agent=\"AGENTB\"/>\n"+
"<transferSet>\n"+
"<item checksumMethod=\"MD5\" mode=\"binary\">\n"+
"<source disposition=\"leave\" recursive=\"false\">\n"+
"<file>c:\\tmp\\icon.gif</file>\n"+
"</source>\n"+
"<destination exist=\"overwrite\" type=\"directory\">\n"+
"<file>C:\\TEST</file>\n"+
"</destination>\n"+
"</item>\n"+
"</transferSet>\n"+
"</managedTransfer>\n"+
"</request>");
System.out.println("The message is: " + s);
msg.writeUTF(s);

// Specify the default put message options
MQPutMessageOptions pmo = new MQPutMessageOptions();

// Put the message to the queue
System.out.println("Sending a message...");
queue.put(msg, pmo);

The file transfer fails because malformed XML, I suppose that is 2 byte of the message length at the beginning of the message.

What is a solution?