timetable-extension #1
@ -1,6 +1,8 @@
 | 
			
		||||
package messaging
 | 
			
		||||
 | 
			
		||||
import (
 | 
			
		||||
	"time"
 | 
			
		||||
 | 
			
		||||
	"git.fjla.uk/owlboard/timetable-mgr/helpers"
 | 
			
		||||
	"git.fjla.uk/owlboard/timetable-mgr/log"
 | 
			
		||||
	"github.com/go-stomp/stomp/v3"
 | 
			
		||||
@ -17,7 +19,7 @@ func StompInit(cfg *helpers.Configuration) {
 | 
			
		||||
func dial(user, pass string) *stomp.Conn {
 | 
			
		||||
	conn, err := stomp.Dial("tcp", "publicdatafeeds.networkrail.co.uk:61618",
 | 
			
		||||
		stomp.ConnOpt.Login(user, pass),
 | 
			
		||||
		stomp.ConnOpt.HeartBeat(15000, 15000),
 | 
			
		||||
		stomp.ConnOpt.HeartBeat(15*time.Second, 15*time.Second),
 | 
			
		||||
		stomp.ConnOpt.Header("client-id", user+"-mq-client"),
 | 
			
		||||
	)
 | 
			
		||||
	if err != nil {
 | 
			
		||||
 | 
			
		||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user