file2mq/file2mq/Program.cs

// ===========================================================================
using System;
using System.IO;
using System.Collections;
using System.Text;

using IBM.WMQ;

class File2Mq
{
    // The type of connection to use, this can be:-
    // MQC.TRANSPORT_MQSERIES_BINDINGS for a server connection.
    // MQC.TRANSPORT_MQSERIES_CLIENT for a non-XA client connection
    // MQC.TRANSPORT_MQSERIES_XACLIENT for an XA client connection
    // MQC.TRANSPORT_MQSERIES_MANAGED for a managed client connection
    const String connectionType = MQC.TRANSPORT_MQSERIES_CLIENT;

    // Define the name of the channel to use (applies to client connections only)
    const String channel = "CLIENT";


    static Hashtable init(String connectionType, string hostName)
    {
        Hashtable connectionProperties = new Hashtable();

        // Add the connection type
        connectionProperties.Add(MQC.TRANSPORT_PROPERTY, connectionType);

        // Set up the rest of the connection properties, based on the
        // connection type requested
        switch (connectionType)
        {
            case MQC.TRANSPORT_MQSERIES_BINDINGS:
                break;
            case MQC.TRANSPORT_MQSERIES_CLIENT:
            case MQC.TRANSPORT_MQSERIES_XACLIENT:
            case MQC.TRANSPORT_MQSERIES_MANAGED:
                connectionProperties.Add(MQC.HOST_NAME_PROPERTY, hostName);
                connectionProperties.Add(MQC.CHANNEL_PROPERTY, channel);
                break;
        }

        return connectionProperties;
    }

    [STAThread]
    static int Main(string[] args)
    {

        if (args.Length != 5)
        {
            Console.WriteLine("Usage: file2mq.exe <server> <queuemanager> <queuename> <file> <archivedir>");
            Console.WriteLine("Ex: file2mq.exe 10.30.1.26 DAOP KISS.IND d:\\data\\test.file d:\\data\\old");
            Environment.Exit(0);
        }

        String hostName = args[0];
        String queueManager = args[1];
        String queueName = args[2];
        String fileName = args[3];
        String archiveDir = args[4];

        if (File.Exists(fileName) == false)
        {
            Console.WriteLine("File does not exists {0}", fileName);
            Environment.Exit(1);
        }

        if (Directory.Exists(archiveDir) == false)
        {
            Console.WriteLine("Archive Directory does not exists {0}", archiveDir);
            Environment.Exit(1);
        }

        
        StreamReader input = null;
        try
        {
            Encoding iso = Encoding.GetEncoding("iso8859-1");
            input = new StreamReader (fileName, iso);
        }
        catch (Exception ex)
        {
            Console.WriteLine("Error opening file: {0}", ex.ToString());
            Environment.Exit(1);
        }


        try
        {
            Hashtable connectionProperties = init(connectionType, hostName);

            // Create a connection to the queue manager using the connection
            // properties just defined
            MQQueueManager qMgr = new MQQueueManager(queueManager, connectionProperties);

            // Set up the options on the queue we want to open
            //int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;
            int openOptions = MQC.MQOO_OUTPUT;

            // Now specify the queue that we want to open,and the open options
            MQQueue out_queue = qMgr.AccessQueue( queueName, openOptions);


            // Specify the message options

            while (input.EndOfStream == false)
            {
                string line = input.ReadLine();
                line = line.Trim();

                if (line.Length == 0) {//put ikke tomme linier i mq
                    continue;
                }

                MQPutMessageOptions pmo = new MQPutMessageOptions(); // accept the defaults,
                // same as MQPMO_DEFAULT

                MQMessage msg = new MQMessage();
                msg.Format = MQC.MQFMT_STRING;
                //msg.CharacterSet = 819; //iso 8859-1
                msg.CharacterSet = 1252; //iso 8859-1
                msg.WriteString(line);

                out_queue.Put(msg, pmo);

            }

            // Close the queue
            out_queue.Close();

            // Disconnect from the queue manager
            qMgr.Disconnect();

            input.Close();

            String baseName = Path.GetFileName(fileName);
            Directory.Move(fileName, archiveDir + "\\" + baseName);
        }

        //If an error has occurred in the above,try to identify what went wrong.
        //Was it a WebSphere MQ error?
        catch (MQException ex)
        {
            Console.WriteLine("A WebSphere MQ error occurred: {0}", ex.ToString());
            Environment.Exit(1);
        }

        catch (System.Exception ex)
        {
            Console.WriteLine("A System error occurred: {0}", ex.ToString());
            Environment.Exit(1);
        }

        
        return 0;
    }
}

/*// Get the message back again

// First define a WebSphere MQ message buffer to receive the message
MQMessage retrievedMessage = new MQMessage();
retrievedMessage.MessageId = hello_world.MessageId;

// Set the get message options
MQGetMessageOptions gmo = new MQGetMessageOptions(); //accept the defaults
//same as MQGMO_DEFAULT

// Get the message off the queue
kiss_ind_queue.Get(retrievedMessage, gmo);

// Prove we have the message by displaying the UTF message text
String msgText = retrievedMessage.ReadUTF();
Console.WriteLine("The message is: {0}", msgText);*/
1	// ===========================================================================
2	using System;
3	using System.IO;
4	using System.Collections;
5	using System.Text;
6
7	using IBM.WMQ;
8
9	class File2Mq
10	{
11	// The type of connection to use, this can be:-
12	// MQC.TRANSPORT_MQSERIES_BINDINGS for a server connection.
13	// MQC.TRANSPORT_MQSERIES_CLIENT for a non-XA client connection
14	// MQC.TRANSPORT_MQSERIES_XACLIENT for an XA client connection
15	// MQC.TRANSPORT_MQSERIES_MANAGED for a managed client connection
16	const String connectionType = MQC.TRANSPORT_MQSERIES_CLIENT;
17
18	// Define the name of the channel to use (applies to client connections only)
19	const String channel = "CLIENT";
20
21
22
23	static Hashtable init(String connectionType, string hostName)
24	{
25	Hashtable connectionProperties = new Hashtable();
26
27	// Add the connection type
28	connectionProperties.Add(MQC.TRANSPORT_PROPERTY, connectionType);
29
30	// Set up the rest of the connection properties, based on the
31	// connection type requested
32	switch (connectionType)
33	{
34	case MQC.TRANSPORT_MQSERIES_BINDINGS:
35	break;
36	case MQC.TRANSPORT_MQSERIES_CLIENT:
37	case MQC.TRANSPORT_MQSERIES_XACLIENT:
38	case MQC.TRANSPORT_MQSERIES_MANAGED:
39	connectionProperties.Add(MQC.HOST_NAME_PROPERTY, hostName);
40	connectionProperties.Add(MQC.CHANNEL_PROPERTY, channel);
41	break;
42	}
43
44	return connectionProperties;
45	}
46
47	[STAThread]
48	static int Main(string[] args)
49	{
50
51	if (args.Length != 5)
52	{
53	Console.WriteLine("Usage: file2mq.exe <server> <queuemanager> <queuename> <file> <archivedir>");
54	Console.WriteLine("Ex: file2mq.exe 10.30.1.26 DAOP KISS.IND d:\\data\\test.file d:\\data\\old");
55	Environment.Exit(0);
56	}
57
58	String hostName = args[0];
59	String queueManager = args[1];
60	String queueName = args[2];
61	String fileName = args[3];
62	String archiveDir = args[4];
63
64	if (File.Exists(fileName) == false)
65	{
66	Console.WriteLine("File does not exists {0}", fileName);
67	Environment.Exit(1);
68	}
69
70	if (Directory.Exists(archiveDir) == false)
71	{
72	Console.WriteLine("Archive Directory does not exists {0}", archiveDir);
73	Environment.Exit(1);
74	}
75
76
77	StreamReader input = null;
78	try
79	{
80	Encoding iso = Encoding.GetEncoding("iso8859-1");
81	input = new StreamReader (fileName, iso);
82	}
83	catch (Exception ex)
84	{
85	Console.WriteLine("Error opening file: {0}", ex.ToString());
86	Environment.Exit(1);
87	}
88
89
90	try
91	{
92	Hashtable connectionProperties = init(connectionType, hostName);
93
94	// Create a connection to the queue manager using the connection
95	// properties just defined
96	MQQueueManager qMgr = new MQQueueManager(queueManager, connectionProperties);
97
98	// Set up the options on the queue we want to open
99	//int openOptions = MQC.MQOO_INPUT_AS_Q_DEF \| MQC.MQOO_OUTPUT;
100	int openOptions = MQC.MQOO_OUTPUT;
101
102	// Now specify the queue that we want to open,and the open options
103	MQQueue out_queue = qMgr.AccessQueue( queueName, openOptions);
104
105
106	// Specify the message options
107
108	while (input.EndOfStream == false)
109	{
110	string line = input.ReadLine();
111	line = line.Trim();
112
113	if (line.Length == 0) {//put ikke tomme linier i mq
114	continue;
115	}
116
117	MQPutMessageOptions pmo = new MQPutMessageOptions(); // accept the defaults,
118	// same as MQPMO_DEFAULT
119
120	MQMessage msg = new MQMessage();
121	msg.Format = MQC.MQFMT_STRING;
122	//msg.CharacterSet = 819; //iso 8859-1
123	msg.CharacterSet = 1252; //iso 8859-1
124	msg.WriteString(line);
125
126	out_queue.Put(msg, pmo);
127
128	}
129
130	// Close the queue
131	out_queue.Close();
132
133	// Disconnect from the queue manager
134	qMgr.Disconnect();
135
136	input.Close();
137
138	String baseName = Path.GetFileName(fileName);
139	Directory.Move(fileName, archiveDir + "\\" + baseName);
140	}
141
142	//If an error has occurred in the above,try to identify what went wrong.
143	//Was it a WebSphere MQ error?
144	catch (MQException ex)
145	{
146	Console.WriteLine("A WebSphere MQ error occurred: {0}", ex.ToString());
147	Environment.Exit(1);
148	}
149
150	catch (System.Exception ex)
151	{
152	Console.WriteLine("A System error occurred: {0}", ex.ToString());
153	Environment.Exit(1);
154	}
155
156
157	return 0;
158	}
159	}
160
161	/*// Get the message back again
162
163	// First define a WebSphere MQ message buffer to receive the message
164	MQMessage retrievedMessage = new MQMessage();
165	retrievedMessage.MessageId = hello_world.MessageId;
166
167	// Set the get message options
168	MQGetMessageOptions gmo = new MQGetMessageOptions(); //accept the defaults
169	//same as MQGMO_DEFAULT
170
171	// Get the message off the queue
172	kiss_ind_queue.Get(retrievedMessage, gmo);
173
174	// Prove we have the message by displaying the UTF message text
175	String msgText = retrievedMessage.ReadUTF();
176	Console.WriteLine("The message is: {0}", msgText);*/