Merge pull request #12 from ibm-messaging/local-transactions

Support for local transactions

Author: matrober-uk

README.md

@@ -118,6 +118,7 @@ your own error handling or logging.
 * Send a message as Persistent or NonPersistent - [deliverymode_test.go](deliverymode_test.go)
 * Get by CorrelationID - [getbycorrelid_test.go](getbycorrelid_test.go)
 * Request/reply messaging pattern - [requestreply_test.go](requestreply_test.go)
+* Send and receive under a local transaction - [local_transaction_test.go](local_transaction_test.go)
 * Sending a message that expires after a period of time - [timetolive_test.go](timetolive_test.go)
 * Handle error codes returned by the queue manager - [sample_errorhandling_test.go](sample_errorhandling_test.go)
 

go.sum

@@ -2,12 +2,14 @@ github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/ibm-messaging/mq-golang v1.0.1-0.20190820103725-19b946c185a8 h1:kUwSXeftVen12FRnShG+Ykhb2Kd6Cd/DbpWwbYal7j0=
 github.com/ibm-messaging/mq-golang v1.0.1-0.20190820103725-19b946c185a8/go.mod h1:qjsZDb7m1oKnbPeDma2JVJTKgyCA91I4bcJ1qHY+gcA=
+github.com/ibm-messaging/mq-golang v3.0.0+incompatible h1:Yc3c8emAyveT54uNDRMkgvS+EBAHeLNWHkc3hk5x+IY=
 github.com/ibm-messaging/mq-golang/v5 v5.0.0 h1:9J8bsDoCo60rbSgB7ZAURPG3L5Kpr+F8dYNOwQ7Qnnk=
 github.com/ibm-messaging/mq-golang/v5 v5.0.0/go.mod h1:ywCwmYbJOU/E0rl+z4GiNoxVMty68O+LVO39a1VMXrE=
 github.com/ibm-messaging/mq-golang/v5 v5.1.2 h1:u0e1Vce2TNqJpH088vF77rDMsnMRWnGaOIlxZo4DMZc=
 github.com/ibm-messaging/mq-golang/v5 v5.1.2/go.mod h1:ywCwmYbJOU/E0rl+z4GiNoxVMty68O+LVO39a1VMXrE=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/stretchr/objx v0.1.0 h1:4G4v2dO3VZwixGIRoQ5Lfboy6nUhCyYzaqnIAPPhYs4=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/testify v1.4.0 h1:2E4SXV/wtOkTonXsotYi4li6zVWxYlZuYNCXe9XRJyk=
 github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=

jms20subset/ConnectionFactory.go

@@ -7,7 +7,7 @@
 //
 // SPDX-License-Identifier: EPL-2.0
 
-// Interfaces for messaging applications in the style of the Java Message Service (JMS) API.
+// Package jms20subset provides interfaces for messaging applications in the style of the Java Message Service (JMS) API.
 package jms20subset
 
 // ConnectionFactory defines a Golang interface which provides similar
@@ -18,5 +18,12 @@ type ConnectionFactory interface {
 
 	// CreateContext creates a connection to the messaging provider using the
 	// configuration parameters that are encapsulated by this ConnectionFactory.
+	//
+	// Defaults to sessionMode of JMSContextAUTOACKNOWLEDGE
 	CreateContext() (JMSContext, JMSException)
+
+	// CreateContextWithSessionMode creates a connection to the messaging provider using the
+	// configuration parameters that are encapsulated by this ConnectionFactory,
+	// and the specified session mode.
+	CreateContextWithSessionMode(sessionMode int) (JMSContext, JMSException)
 }

jms20subset/DeliveryMode.go

@@ -7,15 +7,15 @@
 //
 // SPDX-License-Identifier: EPL-2.0
 
-//
+// Package jms20subset provides interfaces for messaging applications in the style of the Java Message Service (JMS) API.
 package jms20subset
 
 // Go doesn't allow constants in structs so the naming of this file is only for
 // logical grouping purposes. The constants are package scoped, but we use a
 // prefix to the naming in order to maintain similarity with Java JMS.
 
-// Used to configure messages to be sent Persistently.
+// DeliveryMode_PERSISTENT is used to configure messages to be sent Persistently.
 const DeliveryMode_PERSISTENT int = 2
 
-// Used to configure messages to be sent Non-Persistently.
+// DeliveryMode_NON_PERSISTENT is Used to configure messages to be sent Non-Persistently.
 const DeliveryMode_NON_PERSISTENT int = 1

jms20subset/Destination.go

@@ -7,7 +7,7 @@
 //
 // SPDX-License-Identifier: EPL-2.0
 
-//
+// Package jms20subset provides interfaces for messaging applications in the style of the Java Message Service (JMS) API.
 package jms20subset
 
 // Destination encapsulates a provider-specific address, which is typically

jms20subset/JMSConsumer.go

@@ -7,7 +7,7 @@
 //
 // SPDX-License-Identifier: EPL-2.0
 
-//
+// Package jms20subset provides interfaces for messaging applications in the style of the Java Message Service (JMS) API.
 package jms20subset
 
 // JMSConsumer provides the ability for an application to receive messages

jms20subset/JMSContext.go

@@ -7,9 +7,15 @@
 //
 // SPDX-License-Identifier: EPL-2.0
 
-//
+// Package jms20subset provides interfaces for messaging applications in the style of the Java Message Service (JMS) API.
 package jms20subset
 
+// JMSContextAUTOACKNOWLEDGE is used to specify a sessionMode that automatically acknowledge message transmission.
+const JMSContextAUTOACKNOWLEDGE int = 1
+
+// JMSContextSESSIONTRANSACTED is used to specify a sessionMode that requires manual commit/rollback of transactions.
+const JMSContextSESSIONTRANSACTED int = 0
+
 // JMSContext represents a connection to the messaging provider, and
 // provides the capability for applications to create Producer and Consumer
 // objects so that it can send and receive messages.
@@ -54,6 +60,12 @@ type JMSContext interface {
 	// name and different parameters we must use a different function name.
 	CreateTextMessageWithString(txt string) TextMessage
 
+	// Commit confirms all messages sent/received during this transaction.
+	Commit()
+
+	// Rollback releases all messages sent/received during this transaction.
+	Rollback()
+
 	// Closes the connection to the messaging provider.
 	//
 	// Since the provider typically allocates significant resources on behalf of

jms20subset/JMSException.go

@@ -7,7 +7,7 @@
 //
 // SPDX-License-Identifier: EPL-2.0
 
-//
+// Package jms20subset provides interfaces for messaging applications in the style of the Java Message Service (JMS) API.
 package jms20subset
 
 // JMSException represents an interface for returning details of a

jms20subset/JMSProducer.go

@@ -7,7 +7,7 @@
 //
 // SPDX-License-Identifier: EPL-2.0
 
-//
+// Package jms20subset provides interfaces for messaging applications in the style of the Java Message Service (JMS) API.
 package jms20subset
 
 // JMSProducer is a simple object used to send messages on behalf of a

jms20subset/Message.go

@@ -7,7 +7,7 @@
 //
 // SPDX-License-Identifier: EPL-2.0
 
-//
+// Package jms20subset provides interfaces for messaging applications in the style of the Java Message Service (JMS) API.
 package jms20subset
 
 // Message is the root interface of all JMS Messages. It defines the