Apache Active MQ, Spring Integration Messaging sending SWIFT MT950 messages...

I need to send MT950 messages to a SWIFT message, I've done this before but I always forget how I did it. This version, however needs to be a little more comprehensive. Specifically, I want to develop this to send messages from a query, but be able to map the query results to the message fields

so first things first I'm going to need to tool up. I downloaded Apache Active MQ and installed it (basically just uncompresses)




/Users/christopherwebster/Dev/apache-activemq-5.8.0




./bin/activemq console







The above starts Active MQ. In a web browser, navigating to http://localhost:8161/admin/index.jsp
you should see the following

  















So now we've got something to send a message to we can code up a simple test.

here's my pom:

    4.0.0
    cwc
    SwiftMessagePublisher
    1.0.0.BUILD-SNAPSHOT
    jar
    SwiftMessagePublisher
    http://www.springsource.org/spring-integration
  
    
        2.2.1
    
    
        UTF-8
        2.2.4.RELEASE
        1.2.17
        4.11
    
    
        
        repo.springsource.org.milestone
        Spring Framework Maven Milestone Repository
        https://repo.springsource.org/milestone
        
        
        repository.jboss.org-public
        JBoss.org Maven repository
        https://repository.jboss.org/nexus/content/groups/public
        
    
    
        
            
                maven-eclipse-plugin
                2.9
                
                    
                        org.springframework.ide.eclipse.core.springnature
                        
                    
                        org.springframework.ide.eclipse.core.springbuilder
                    
                    true
                    true
                
            
            
                org.apache.maven.plugins
                maven-compiler-plugin
                3.0
                
                    1.6
                    1.6
                    -Xlint:all
                    true
                    true
                
            
            
                org.codehaus.mojo
                exec-maven-plugin
                1.2.1
                
                    com.cwc.swiftmessagepublisher.Main
                
            
        
    
    
        
        
            junit
            junit
            ${junit.version}
            test
        
        
            javax.jms
            jms
            1.1
        
        
        
            org.springframework
            spring-jms
            3.1.2.RELEASE
            
        
            org.springframework.integration
            spring-integration-jms
            2.1.3.RELEASE
            
        
            org.apache.activemq
            activemq-core
            LATEST
            
        
            org.apache.activemq
            activemq-pool
            LATEST
            
        
            org.springframework.integration
            spring-integration-core
            ${spring.integration.version}
            
        
            org.springframework.integration
            spring-integration-file
            ${spring.integration.version}
            
        
        log4j
            log4j
            ${log4j.version}
        
        
        
            commons-io
            commons-io
            2.4
        
    

Create a project and add this in eclipse. Here's mine...


I've used STS here and created a Spring project. I added maven and modified the POM. You need a couple of alternative repos because some of the dependencies aren't covered by the defaults.

notice the spring integration context. STS adds this for a Sprint Integration project by default.















You'll notice the testSend() :void test. I added this just to get the go-no-go test proved with Active MQ. Here's the code, no spring in there yet. I just want to prove that I can successfully send a message to the Queue.




@Test

public void testSend(){

try {

            //created ConnectionFactory object for creating connection 

            ConnectionFactory factory = new ActiveMQConnectionFactory("admin", "admin", "tcp://localhost:61616");

            //Establish the connection

            Connection connection = factory.createConnection();

            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

            Queue queue = session.createQueue("TEST-QUEUE");

            //Added as a producer

            javax.jms.MessageProducer producer = session.createProducer(queue);

            // Create and send the message

            TextMessage msg = session.createTextMessage();

            msg.setText("Hello World");

            producer.send(msg);

        } catch (Exception e) {

            // TODO: handle exception

        e.getMessage();

        }

}

So running the tests...

We're good, all compiles and runs.. but did we send a message?

Switch to the ActiveMQ Console and review Queues. Click the queue name and you'll see there's a message. Click the message to review the payload and we can see we've got a "Hello World" message.

OK so to review, we've installed Apache Active MQ, retaining the defaults. Created a Spring Integration Project in STS (Spring Source Tool Suite) and added a test that sends a hello world message to Active MQ. We've tested the development harness and we're ready to start generating and testing SWIFT messages.

...not bad for a hour or so's work.