1 files changed, 9 insertions, 3 deletions
diff --git a/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/Connection.java b/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/Connection.java
index 323f6c877c..04241cd468 100644
--- a/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/Connection.java
+++ b/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/Connection.java
@@ -44,7 +44,7 @@ public interface Connection
      * @param name Unique identifier for the session.
      * @return Session
      */
-    public Session createSession(String name)throws MessagingException;
+    public Session createSession(String name) throws MessagingException;
 
     /**
      * Creates a transactional session with the given name.
@@ -53,7 +53,7 @@ public interface Connection
      * @param name Unique identifier for the session.
      * @return Session
      */
-    public Session createTransactionalSession(String name)throws MessagingException;
+    public Session createTransactionalSession(String name) throws MessagingException;
 
     /**
      * Returns the authenticated username for this connection.
@@ -62,5 +62,11 @@ public interface Connection
      * For KERBEROS the username will be the kerberos username.
      * @return The authenticated username.
      */
-    public String getAuthenticatedUsername()throws MessagingException;
+    public String getAuthenticatedUsername() throws MessagingException;
+
+    /**
+     * Returns a reference to the message factory for this connection.
+     * @return MessageFactory
+     */
+    public MessageFactory getMessageFactory();
 }