Apply stomp v3

core-go · Jul 21, 2024 · f3662ef · f3662ef
1 parent 6f05dad
commit f3662ef
Show file tree

Hide file tree

Showing 5 changed files with 13 additions and 8 deletions.
diff --git a/conn.go b/conn.go
@@ -1,10 +1,11 @@
 package activemq
 
 import (
-	"github.com/go-stomp/stomp"
 	"log"
 	"os"
 	"time"
+
+	"github.com/go-stomp/stomp/v3"
 )
 
 func NewConn(userName string, password string, addr string) (*stomp.Conn, error) {

diff --git a/destination_sender.go b/destination_sender.go
@@ -2,7 +2,8 @@ package activemq
 
 import (
 	"context"
-	"github.com/go-stomp/stomp"
+
+	"github.com/go-stomp/stomp/v3"
 )
 
 type DestinationSender struct {

diff --git a/health_checker.go b/health_checker.go
@@ -2,7 +2,8 @@ package activemq
 
 import (
 	"context"
-	"github.com/go-stomp/stomp"
+
+	"github.com/go-stomp/stomp/v3"
 )
 
 type HealthChecker struct {
@@ -26,7 +27,7 @@ func (s *HealthChecker) Name() string {
 
 func (s *HealthChecker) Check(ctx context.Context) (map[string]interface{}, error) {
 	var conn *stomp.Conn
-	
+
 	res := make(map[string]interface{})
 	var err error
 	conn, err = stomp.Dial("tcp", s.addr)

diff --git a/sender.go b/sender.go
@@ -2,8 +2,9 @@ package activemq
 
 import (
 	"context"
-	"github.com/go-stomp/stomp"
-	"github.com/go-stomp/stomp/frame"
+
+	"github.com/go-stomp/stomp/v3"
+	"github.com/go-stomp/stomp/v3/frame"
 )
 
 type Sender struct {

diff --git a/subscriber.go b/subscriber.go
@@ -2,9 +2,10 @@ package activemq
 
 import (
 	"context"
-	"github.com/go-stomp/stomp"
-	"github.com/go-stomp/stomp/frame"
 	"time"
+
+	"github.com/go-stomp/stomp/v3"
+	"github.com/go-stomp/stomp/v3/frame"
 )
 
 type Subscriber struct {