commit
						279c226404
					
				| 
						 | 
				
			
			@ -43,7 +43,7 @@ func publishWithJetStream(streamName, subject string, data []byte) (isPublished
 | 
			
		|||
	var req = RequestBody{Body: data}
 | 
			
		||||
 | 
			
		||||
	// Publish jet stream
 | 
			
		||||
	if err := client.natsJetStream.Publish(streamName, subject, toBytes(req)); err != nil {
 | 
			
		||||
	if err = client.natsJetStream.Publish(streamName, subject, toBytes(req)); err != nil {
 | 
			
		||||
		return
 | 
			
		||||
	}
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
							
								
								
									
										6
									
								
								go.mod
								
								
								
								
							
							
						
						
									
										6
									
								
								go.mod
								
								
								
								
							| 
						 | 
				
			
			@ -1,10 +1,14 @@
 | 
			
		|||
module github.com/Selly-Modules/appier
 | 
			
		||||
 | 
			
		||||
go 1.16
 | 
			
		||||
go 1.17
 | 
			
		||||
 | 
			
		||||
require github.com/Selly-Modules/natsio v0.0.0-20220321031929-3fe4271f1bbc
 | 
			
		||||
 | 
			
		||||
require (
 | 
			
		||||
	github.com/logrusorgru/aurora v2.0.3+incompatible // indirect
 | 
			
		||||
	github.com/nats-io/nats.go v1.13.0 // indirect
 | 
			
		||||
	github.com/nats-io/nkeys v0.3.0 // indirect
 | 
			
		||||
	github.com/nats-io/nuid v1.0.1 // indirect
 | 
			
		||||
	github.com/thoas/go-funk v0.9.2 // indirect
 | 
			
		||||
	golang.org/x/crypto v0.0.0-20220315160706-3147a52a75dd // indirect
 | 
			
		||||
)
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
		Loading…
	
		Reference in New Issue