type Server struct {
session *
sqsClient *
snsClient *
s3Client *s3.S3
b string
ch string
}
func (s *Server) Message() error {
// URL to our queue
qURL := ("/xx311/xx_%s_queue_%s", , )
resultSQS, err := (&{
AttributeNames: []*string{
(),
},
MessageAttributeNames: []*string{
(),
},
QueueUrl: &qURL,
MaxNumberOfMessages: aws.Int64(10),
VisibilityTimeout: aws.Int64(60), // seconds
WaitTimeSeconds: aws.Int64(1),
})
if err != nil {
("Error: %+v\n", err)
return err
}
if len() > 0 {
for _, msg := range {
var receivedMessage
var pEvent
delete_params := &{
QueueUrl: &qURL,
ReceiptHandle: ,
}
_, err := (delete_params)
if err != nil {
("delete message failed: %v", err)
continue
}
// s.Printf("pipeline state: %v\n", *)
if err := ([]byte(*), &receivedMessage); err != nil {
("malformat SQS Message %v", err)
continue
}
("TEST %s\n", )
if err := ([]byte(), &pipelineEvent); err != nil {
("malformat P Message %v", err)
}
}
}
return nil
}