Skip to content

Commit

Permalink
Final fixes for this branch per @jsha
Browse files Browse the repository at this point in the history
  • Loading branch information
jcjones committed Feb 19, 2015
1 parent a28a0e7 commit 5d5b65f
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
4 changes: 2 additions & 2 deletions activity-monitor/activity-monitor.go
Original file line number Diff line number Diff line change
Expand Up @@ -89,7 +89,7 @@ func startMonitor(AmqpUrl string, logger *boulder.JsonLogger) {
return
}

delveries, err := rpcCh.Consume(
deliveries, err := rpcCh.Consume(
QueueName,
consumerTag,
AmqpAutoAck,
Expand All @@ -103,7 +103,7 @@ func startMonitor(AmqpUrl string, logger *boulder.JsonLogger) {
}

// Run forever.
for d := range delveries {
for d := range deliveries {
// Pass each message to the Analysis Engine
ae.ProcessMessage(d)
// Only ack the delivery we actually handled (ackMultiple=false)
Expand Down
8 changes: 4 additions & 4 deletions json-logger.go
Original file line number Diff line number Diff line change
Expand Up @@ -25,8 +25,8 @@ import (
// be restarted by the process controller.


// Use the same severity levels as RFC 5424.
// Note: Facility is not used.
// Use the same Severity levels as RFC 5424.
// Note: RFC 5424 Facility is not used.
const (
EMERGENCY = 0
ALERT = 1
Expand All @@ -52,8 +52,8 @@ type LogMessage struct {

// Structure to hold logger details.
type JsonLogger struct {
stdout bool // True if logging to stdout
online bool // True if the remote endpoint has been setup
stdout bool // True if logging to stdout (independent of network)
online bool // True if logging to network
scheme string // Golang net URI scheme (tcp/udp)
host string // "address:port"
level int // Maximum-transmitted log level
Expand Down

0 comments on commit 5d5b65f

Please sign in to comment.