Adding isClosed method

README.md

@@ -14,10 +14,10 @@ Features:
 ## Usage Instructions
 
 ```
-go get github.com/go-stomp/stomp
+go get github.com/ingelectus/stomp
 ```
 
-For API documentation, see http://godoc.org/github.com/go-stomp/stomp
+For API documentation, see http://godoc.org/github.com/ingelectus/stomp
 
 ## Previous Version
 

ack.go

@@ -1,7 +1,7 @@
 package stomp
 
 import (
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 )
 
 // The AckMode type is an enumeration of the acknowledgement modes for a

breaking_changes.md

@@ -19,7 +19,7 @@ import (
 Version 2:
 ```go
 import (
-    "github.com/go-stomp/stomp"
+    "github.com/ingelectus/stomp"
 )
 ```
 
@@ -46,11 +46,11 @@ package, and the types moved are not needed in normal usage of the `stomp` packa
 Version 2 of the stomp library makes use of functional options to provide a clean, flexible way
 of specifying options in the following API calls:
 
-* [Dial()](http://godoc.org/github.com/go-stomp/stomp#Dial)
-* [Connect()](http://godoc.org/github.com/go-stomp/stomp#Connect)
-* [Conn.Send()](http://godoc.org/github.com/go-stomp/stomp#Conn.Send)
-* [Transaction.Send()](http://godoc.org/github.com/go-stomp/stomp#Transaction.Send)
-* [Conn.Subscribe()](http://godoc.org/github.com/go-stomp/stomp#Conn.Subscribe)
+* [Dial()](http://godoc.org/github.com/ingelectus/stomp#Dial)
+* [Connect()](http://godoc.org/github.com/ingelectus/stomp#Connect)
+* [Conn.Send()](http://godoc.org/github.com/ingelectus/stomp#Conn.Send)
+* [Transaction.Send()](http://godoc.org/github.com/ingelectus/stomp#Transaction.Send)
+* [Conn.Subscribe()](http://godoc.org/github.com/ingelectus/stomp#Conn.Subscribe)
 
 The idea for this comes from Dave Cheney's very excellent blog post,
 [Functional Options for Friendly APIs](http://dave.cheney.net/2014/10/17/functional-options-for-friendly-apis).

conn.go

@@ -9,7 +9,7 @@ import (
 	"sync"
 	"time"
 
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 )
 
 // Default time span to add to read/write heart-beat timeouts
@@ -683,3 +683,8 @@ func (c *Conn) createAckNackFrame(msg *Message, ack bool) (*frame.Frame, error)
 
 	return f, nil
 }
+
+// IsClosed checks if active stomp connection is closed
+func (c *Conn) IsClosed() bool {
+	return c.closed
+}

conn_options.go

@@ -5,7 +5,7 @@ import (
 	"strings"
 	"time"
 
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 )
 
 // ConnOptions is an opaque structure used to collection options

conn_test.go

@@ -5,8 +5,8 @@ import (
 	"io"
 	"time"
 
-	"github.com/go-stomp/stomp/frame"
-	"github.com/go-stomp/stomp/testutil"
+	"github.com/ingelectus/stomp/frame"
+	"github.com/ingelectus/stomp/testutil"
 	. "gopkg.in/check.v1"
 )
 

errors.go

@@ -1,7 +1,7 @@
 package stomp
 
 import (
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 )
 
 // Error values

example_test.go

@@ -5,8 +5,8 @@ import (
 	"net"
 	"time"
 
-	"github.com/go-stomp/stomp"
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp"
+	"github.com/ingelectus/stomp/frame"
 )
 
 func ExampleConn_Send(c *stomp.Conn) error {

examples/client_test/main.go

@@ -5,7 +5,7 @@ import (
 	"fmt"
 	"os"
 
-	"github.com/go-stomp/stomp"
+	"github.com/ingelectus/stomp"
 )
 
 const defaultPort = ":61613"

message.go

@@ -1,7 +1,7 @@
 package stomp
 
 import (
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 )
 
 // A Message represents a message received from the STOMP server.

send_options.go

@@ -1,7 +1,7 @@
 package stomp
 
 import (
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 )
 
 // SendOpt contains options for for the Conn.Send and Transaction.Send functions.

server/client/conn.go

@@ -8,8 +8,8 @@ import (
 	"strconv"
 	"time"
 
-	"github.com/go-stomp/stomp"
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp"
+	"github.com/ingelectus/stomp/frame"
 )
 
 // Maximum number of pending frames allowed to a client.

server/client/frame.go

@@ -6,8 +6,8 @@ import (
 	"strconv"
 	"strings"
 
-	"github.com/go-stomp/stomp"
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp"
+	"github.com/ingelectus/stomp/frame"
 )
 
 const (

server/client/frame_test.go

@@ -1,8 +1,8 @@
 package client
 
 import (
-	"github.com/go-stomp/stomp"
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp"
+	"github.com/ingelectus/stomp/frame"
 	. "gopkg.in/check.v1"
 )
 

server/client/request.go

@@ -3,7 +3,7 @@ package client
 import (
 	"strconv"
 
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 )
 
 // Opcode used in client requests.

server/client/subscription.go

@@ -1,7 +1,7 @@
 package client
 
 import (
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 )
 
 type Subscription struct {

server/client/tx_store.go

@@ -3,7 +3,7 @@ package client
 import (
 	"container/list"
 
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 )
 
 type txStore struct {

server/client/tx_store_test.go

@@ -1,7 +1,7 @@
 package client
 
 import (
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 	. "gopkg.in/check.v1"
 )
 

server/processor.go

@@ -6,10 +6,10 @@ import (
 	"strings"
 	"time"
 
-	"github.com/go-stomp/stomp/frame"
-	"github.com/go-stomp/stomp/server/client"
-	"github.com/go-stomp/stomp/server/queue"
-	"github.com/go-stomp/stomp/server/topic"
+	"github.com/ingelectus/stomp/frame"
+	"github.com/ingelectus/stomp/server/client"
+	"github.com/ingelectus/stomp/server/queue"
+	"github.com/ingelectus/stomp/server/topic"
 )
 
 type requestProcessor struct {

server/queue/memory_queue.go

@@ -3,7 +3,7 @@ package queue
 import (
 	"container/list"
 
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 )
 
 // In-memory implementation of the QueueStorage interface.

server/queue/memory_queue_test.go

@@ -1,7 +1,7 @@
 package queue
 
 import (
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 	. "gopkg.in/check.v1"
 )
 

server/queue/queue.go

@@ -4,8 +4,8 @@ Package queue provides implementations of server-side queues.
 package queue
 
 import (
-	"github.com/go-stomp/stomp/frame"
-	"github.com/go-stomp/stomp/server/client"
+	"github.com/ingelectus/stomp/frame"
+	"github.com/ingelectus/stomp/server/client"
 )
 
 // Queue for storing message frames.

server/queue/storage.go

@@ -1,7 +1,7 @@
 package queue
 
 import (
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 )
 
 // Interface for queue storage. The intent is that

server/queue_storage.go

@@ -1,7 +1,7 @@
 package server
 
 import (
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 )
 
 // QueueStorage is an interface that abstracts the queue storage mechanism.

server/server_test.go

@@ -6,7 +6,7 @@ import (
 	"runtime"
 	"testing"
 
-	"github.com/go-stomp/stomp"
+	"github.com/ingelectus/stomp"
 	. "gopkg.in/check.v1"
 )
 

server/topic/subscription.go

@@ -1,7 +1,7 @@
 package topic
 
 import (
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 )
 
 // Subscription is the interface that wraps a subscriber to a topic.

server/topic/topic.go

@@ -6,7 +6,7 @@ package topic
 import (
 	"container/list"
 
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 )
 
 // A Topic is used for broadcasting to subscribed clients.

server/topic/topic_test.go

@@ -1,7 +1,7 @@
 package topic
 
 import (
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 	. "gopkg.in/check.v1"
 )
 

stomp.go

@@ -20,7 +20,7 @@ Disconnect method. This will perform a graceful shutdown sequence as specified i
 
 Source code and other details for the project are available at GitHub:
 
-   https://github.com/go-stomp/stomp
+   https://github.com/ingelectus/stomp
 
 */
 package stomp

stompd/main.go

@@ -18,7 +18,7 @@ import (
 	"net"
 	"os"
 
-	"github.com/go-stomp/stomp/server"
+	"github.com/ingelectus/stomp/server"
 )
 
 // TODO: experimenting with ways to gracefully shutdown the server,

subscribe_options.go

@@ -1,7 +1,7 @@
 package stomp
 
 import (
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 )
 
 // SubscribeOpt contains options for for the Conn.Subscribe function.

subscription.go

@@ -6,7 +6,7 @@ import (
 	"sync"
 	"sync/atomic"
 
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 )
 
 const (

transaction.go

@@ -1,7 +1,7 @@
 package stomp
 
 import (
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 )
 
 // A Transaction applies to the sending of messages to the STOMP server,

validator.go

@@ -1,7 +1,7 @@
 package stomp
 
 import (
-	"github.com/go-stomp/stomp/frame"
+	"github.com/ingelectus/stomp/frame"
 )
 
 // Validator is an interface for validating STOMP frames.

version_test.go

@@ -3,7 +3,7 @@ package stomp_test
 import (
 	"testing"
 
-	"github.com/go-stomp/stomp"
+	"github.com/ingelectus/stomp"
 )
 
 func TestSupportsNack(t *testing.T) {