"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "nsqd/topic_test.go" between
nsq-1.2.0.tar.gz and nsq-1.2.1.tar.gz

About: nsq is a realtime distributed and and decentralized messaging platform.

topic_test.go  (nsq-1.2.0)	:	topic_test.go  (nsq-1.2.1)
skipping to change at line 57		skipping to change at line 57
test.Equal(t, "ch1", channel1.name)		test.Equal(t, "ch1", channel1.name)
channel2 := topic.GetChannel("ch2")		channel2 := topic.GetChannel("ch2")
test.Equal(t, channel1, topic.channelMap["ch1"])		test.Equal(t, channel1, topic.channelMap["ch1"])
test.Equal(t, channel2, topic.channelMap["ch2"])		test.Equal(t, channel2, topic.channelMap["ch2"])
}		}
type errorBackendQueue struct{}		type errorBackendQueue struct{}
func (d *errorBackendQueue) Put([]byte) error { return errors.New("never go		func (d *errorBackendQueue) Put([]byte) error { return errors.New("never
nna happen") }		gonna happen") }
func (d *errorBackendQueue) ReadChan() chan []byte { return nil }		func (d *errorBackendQueue) ReadChan() <-chan []byte { return nil }
func (d *errorBackendQueue) Close() error { return nil }		func (d *errorBackendQueue) Close() error { return nil }
func (d *errorBackendQueue) Delete() error { return nil }		func (d *errorBackendQueue) Delete() error { return nil }
func (d *errorBackendQueue) Depth() int64 { return 0 }		func (d *errorBackendQueue) Depth() int64 { return 0 }
func (d *errorBackendQueue) Empty() error { return nil }		func (d *errorBackendQueue) Empty() error { return nil }
type errorRecoveredBackendQueue struct{ errorBackendQueue }		type errorRecoveredBackendQueue struct{ errorBackendQueue }
func (d *errorRecoveredBackendQueue) Put([]byte) error { return nil }		func (d *errorRecoveredBackendQueue) Put([]byte) error { return nil }
func TestHealth(t *testing.T) {		func TestHealth(t *testing.T) {
opts := NewOptions()		opts := NewOptions()
opts.Logger = test.NewTestLogger(t)		opts.Logger = test.NewTestLogger(t)
opts.MemQueueSize = 2		opts.MemQueueSize = 2
_, httpAddr, nsqd := mustStartNSQD(opts)		_, httpAddr, nsqd := mustStartNSQD(opts)
End of changes. 1 change blocks.
7 lines changed or deleted		7 lines changed or added

---