Permalink
Browse files

Official project name: dispatchd

  • Loading branch information...
jeffjenkins committed Nov 28, 2015
1 parent 1dd86fb commit 93de0472e4859116b7130de86b6a07c21efd5f54
View
@@ -21,7 +21,7 @@ func TestBasicFieldArray(t *testing.T) {
func TestBasicTable(t *testing.T) {
// Create
var table = NewTable()
table.SetKey("product", "mq")
table.SetKey("product", "dispatchd")
table.SetKey("version", uint8(7))
table.SetKey("version", uint8(6)) // for code coverage, reset a value
err := table.SetKey("bad", make(map[bool]bool)) // for code coverage, a type it doesn't understand
View
@@ -3,7 +3,7 @@ package amqp
import (
"errors"
"fmt"
"github.com/jeffjenkins/mq/util"
"github.com/jeffjenkins/dispatchd/util"
"io"
"regexp"
)
View
@@ -7,9 +7,9 @@ import (
"fmt"
"github.com/boltdb/bolt"
"github.com/gogo/protobuf/proto"
"github.com/jeffjenkins/mq/amqp"
"github.com/jeffjenkins/mq/gen"
"github.com/jeffjenkins/mq/persist"
"github.com/jeffjenkins/dispatchd/amqp"
"github.com/jeffjenkins/dispatchd/gen"
"github.com/jeffjenkins/dispatchd/persist"
"regexp"
"strings"
)
View
@@ -5,7 +5,7 @@ import (
"encoding/json"
"fmt"
"github.com/boltdb/bolt"
"github.com/jeffjenkins/mq/amqp"
"github.com/jeffjenkins/dispatchd/amqp"
"os"
"testing"
)
View
@@ -2,9 +2,9 @@ package consumer
import (
"encoding/json"
"github.com/jeffjenkins/mq/amqp"
"github.com/jeffjenkins/mq/msgstore"
"github.com/jeffjenkins/mq/stats"
"github.com/jeffjenkins/dispatchd/amqp"
"github.com/jeffjenkins/dispatchd/msgstore"
"github.com/jeffjenkins/dispatchd/stats"
"sync"
)
View
@@ -5,10 +5,10 @@ import (
"fmt"
"github.com/boltdb/bolt"
"github.com/gogo/protobuf/proto"
"github.com/jeffjenkins/mq/amqp"
"github.com/jeffjenkins/mq/binding"
"github.com/jeffjenkins/mq/gen"
"github.com/jeffjenkins/mq/persist"
"github.com/jeffjenkins/dispatchd/amqp"
"github.com/jeffjenkins/dispatchd/binding"
"github.com/jeffjenkins/dispatchd/gen"
"github.com/jeffjenkins/dispatchd/persist"
"sync"
"time"
)
@@ -4,8 +4,8 @@ import (
"encoding/json"
"fmt"
"github.com/boltdb/bolt"
"github.com/jeffjenkins/mq/amqp"
"github.com/jeffjenkins/mq/binding"
"github.com/jeffjenkins/dispatchd/amqp"
"github.com/jeffjenkins/dispatchd/binding"
"os"
"reflect"
"testing"
View
@@ -1,6 +1,6 @@
package gen;
import "github.com/jeffjenkins/mq/amqp/amqp.proto";
import "github.com/jeffjenkins/dispatchd/amqp/amqp.proto";
import "github.com/gogo/protobuf/gogoproto/gogo.proto";
option (gogoproto.marshaler_all) = true;
View
@@ -7,8 +7,8 @@ import (
"fmt"
"github.com/boltdb/bolt"
"github.com/gogo/protobuf/proto"
"github.com/jeffjenkins/mq/amqp"
"github.com/jeffjenkins/mq/stats"
"github.com/jeffjenkins/dispatchd/amqp"
"github.com/jeffjenkins/dispatchd/stats"
"sync"
)
@@ -3,7 +3,7 @@ package msgstore
import (
// "container/list"
"fmt"
"github.com/jeffjenkins/mq/amqp"
"github.com/jeffjenkins/dispatchd/amqp"
"os"
"testing"
)
View
@@ -3,7 +3,7 @@ package msgstore
import (
"fmt"
"github.com/boltdb/bolt"
"github.com/jeffjenkins/mq/amqp"
"github.com/jeffjenkins/dispatchd/amqp"
"reflect"
)
View
@@ -7,12 +7,12 @@ import (
"fmt"
"github.com/boltdb/bolt"
"github.com/gogo/protobuf/proto"
"github.com/jeffjenkins/mq/amqp"
"github.com/jeffjenkins/mq/consumer"
"github.com/jeffjenkins/mq/gen"
"github.com/jeffjenkins/mq/msgstore"
"github.com/jeffjenkins/mq/persist"
"github.com/jeffjenkins/mq/stats"
"github.com/jeffjenkins/dispatchd/amqp"
"github.com/jeffjenkins/dispatchd/consumer"
"github.com/jeffjenkins/dispatchd/gen"
"github.com/jeffjenkins/dispatchd/msgstore"
"github.com/jeffjenkins/dispatchd/persist"
"github.com/jeffjenkins/dispatchd/stats"
"sync"
"time"
)
View
@@ -1,9 +1,9 @@
package main
import (
"github.com/jeffjenkins/mq/amqp"
"github.com/jeffjenkins/mq/stats"
"github.com/jeffjenkins/mq/util"
"github.com/jeffjenkins/dispatchd/amqp"
"github.com/jeffjenkins/dispatchd/stats"
"github.com/jeffjenkins/dispatchd/util"
)
func (channel *Channel) basicRoute(methodFrame amqp.MethodFrame) *amqp.AMQPError {
View
@@ -4,10 +4,10 @@ import (
"bytes"
"errors"
"fmt"
"github.com/jeffjenkins/mq/amqp"
"github.com/jeffjenkins/mq/consumer"
"github.com/jeffjenkins/mq/queue"
"github.com/jeffjenkins/mq/stats"
"github.com/jeffjenkins/dispatchd/amqp"
"github.com/jeffjenkins/dispatchd/consumer"
"github.com/jeffjenkins/dispatchd/queue"
"github.com/jeffjenkins/dispatchd/stats"
"math"
"sync"
)
View
@@ -1,7 +1,7 @@
package main
import (
"github.com/jeffjenkins/mq/amqp"
"github.com/jeffjenkins/dispatchd/amqp"
)
func (channel *Channel) channelRoute(methodFrame amqp.MethodFrame) *amqp.AMQPError {
View
@@ -1,7 +1,7 @@
package main
import (
"github.com/jeffjenkins/mq/amqp"
"github.com/jeffjenkins/dispatchd/amqp"
)
func (channel *Channel) confirmRoute(methodFrame amqp.MethodFrame) *amqp.AMQPError {
View
@@ -4,9 +4,9 @@ import (
"bytes"
"encoding/json"
"fmt"
"github.com/jeffjenkins/mq/amqp"
"github.com/jeffjenkins/mq/stats"
"github.com/jeffjenkins/mq/util"
"github.com/jeffjenkins/dispatchd/amqp"
"github.com/jeffjenkins/dispatchd/stats"
"github.com/jeffjenkins/dispatchd/util"
"net"
"sync"
"time"
@@ -1,7 +1,7 @@
package main
import (
"github.com/jeffjenkins/mq/amqp"
"github.com/jeffjenkins/dispatchd/amqp"
"time"
)
@@ -90,13 +90,13 @@ func (channel *Channel) startConnection() *amqp.AMQPError {
// TODO: the java rabbitmq client I'm using for load testing doesn't like these string
// fields even though the go/python clients do. If they are set as longstr (bytes)
// instead they work, so I'm doing that for now
serverProps.SetKey("product", []byte("mq"))
serverProps.SetKey("product", []byte("dispatchd"))
serverProps.SetKey("version", []byte("0.1"))
serverProps.SetKey("copyright", []byte("Jeffrey Jenkins, 2015"))
serverProps.SetKey("capabilities", capabilities)
serverProps.SetKey("platform", []byte("TODO"))
serverProps.SetKey("host", []byte("TODO"))
serverProps.SetKey("information", []byte("https://github.com/jeffjenkins/mq"))
serverProps.SetKey("information", []byte("https://github.com/jeffjenkins/dispatchd"))
channel.SendMethod(&amqp.ConnectionStart{0, 9, serverProps, []byte("PLAIN"), []byte("en_US")})
return nil
@@ -16,7 +16,7 @@ func handleConnection(server *Server, conn net.Conn) {
func main() {
runtime.SetBlockProfileRate(1)
var server = NewServer("mq.db")
var server = NewServer("dispatchd.db")
ln, err := net.Listen("tcp", ":1111")
if err != nil {
fmt.Printf("Error!\n")
@@ -2,8 +2,8 @@ package main
import (
_ "fmt"
"github.com/jeffjenkins/mq/amqp"
"github.com/jeffjenkins/mq/exchange"
"github.com/jeffjenkins/dispatchd/amqp"
"github.com/jeffjenkins/dispatchd/exchange"
"strings"
)
View
@@ -2,10 +2,10 @@ package main
import (
"fmt"
"github.com/jeffjenkins/mq/amqp"
"github.com/jeffjenkins/mq/binding"
"github.com/jeffjenkins/mq/queue"
"github.com/jeffjenkins/mq/util"
"github.com/jeffjenkins/dispatchd/amqp"
"github.com/jeffjenkins/dispatchd/binding"
"github.com/jeffjenkins/dispatchd/queue"
"github.com/jeffjenkins/dispatchd/util"
)
func (channel *Channel) queueRoute(methodFrame amqp.MethodFrame) *amqp.AMQPError {
View
@@ -5,11 +5,11 @@ import (
"errors"
"fmt"
"github.com/boltdb/bolt"
"github.com/jeffjenkins/mq/amqp"
"github.com/jeffjenkins/mq/binding"
"github.com/jeffjenkins/mq/exchange"
"github.com/jeffjenkins/mq/msgstore"
"github.com/jeffjenkins/mq/queue"
"github.com/jeffjenkins/dispatchd/amqp"
"github.com/jeffjenkins/dispatchd/binding"
"github.com/jeffjenkins/dispatchd/exchange"
"github.com/jeffjenkins/dispatchd/msgstore"
"github.com/jeffjenkins/dispatchd/queue"
"net"
"sync"
)
View
@@ -1,7 +1,7 @@
package main
import (
"github.com/jeffjenkins/mq/amqp"
"github.com/jeffjenkins/dispatchd/amqp"
)
func (channel *Channel) txRoute(methodFrame amqp.MethodFrame) *amqp.AMQPError {

0 comments on commit 93de047

Please sign in to comment.