-
Notifications
You must be signed in to change notification settings - Fork 9
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Listening to multiple queues #17
Conversation
3bb5ae5
to
91427d1
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
Expect(handler.run).To(BeTrue()) | ||
}) | ||
}) | ||
// Describe("Handle Messages", func() { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
why is this test commented?
Expect(handler.run).To(BeTrue()) | ||
}) | ||
}) | ||
// Describe("Handle Messages", func() { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
why is this test also commented?
l := t.Logger.WithFields(logrus.Fields{ | ||
"method": "HandleToken", | ||
"token": token, | ||
}) | ||
l.Debug("deleting token") | ||
query := fmt.Sprintf("DELETE FROM %s WHERE token = ?0;", t.tableName) | ||
query := fmt.Sprintf("DELETE FROM %s WHERE token = ?0;", game+"_"+platform) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I am not sure all games respect this rule =(
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
omg, we need to be sure @guilhermef
91427d1
to
dc03844
Compare
dc03844
to
36bcdcf
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
lgtm, we just need to be sure about the token_pg extension table name
l := t.Logger.WithFields(logrus.Fields{ | ||
"method": "HandleToken", | ||
"token": token, | ||
}) | ||
l.Debug("deleting token") | ||
query := fmt.Sprintf("DELETE FROM %s WHERE token = ?0;", t.tableName) | ||
query := fmt.Sprintf("DELETE FROM %s WHERE token = ?0;", game+"_"+platform) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
omg, we need to be sure @guilhermef
Listens to multiple queues and routes the message to the desired app.