private void sendMessage()

in MQProducer/src/main/java/com/example/apacheMQLabs/mqProducer.java [107:136]

21 lines of code
2 McCabe index (conditional complexity)


	private void sendMessage(LambdaLogger logger, PooledConnectionFactory pooledConnFacty) {
		//Get time
    	SimpleDateFormat timeformatter= new SimpleDateFormat("yyyy-MM-dd 'at' HH:mm:ss z");
    	Date currentTime = new Date();
    	//logger.log("Datetime: " + currentTime.toString() + " \n");
		
    	try {    	
	    	//Establish connection
	        Connection conn = pooledConnFacty.createConnection(user, password);
	        conn.setClientID("AmazonMQ Networks Brokers lab-" + System.currentTimeMillis());
	        conn.start();
	            
	        //Create broker session and send message
	        Session brokerSession = conn.createSession(false, Session.CLIENT_ACKNOWLEDGE);
	        MessageProducer qProducer = brokerSession.createProducer(brokerSession.createQueue(queueName));
	        TextMessage messageToSend = brokerSession.createTextMessage(String.format("Test message at " + timeformatter.format(currentTime).toString()));
	        qProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
	        qProducer.send(messageToSend);
	        logger.log("The message sent was: " + messageToSend.getText() + " \n");

	        //close
	        qProducer.close();
	        brokerSession.close();
	        conn.close();    
	          
	    } catch (JMSException ex) {
	    	System.out.println(String.format("Error: %s", ex.getMessage()));
	        System.exit(1);
	    }		
	}