+func TestSubscribeChannelDBTwoSubscribesWithUnequalPrefixAndUnsubscribes(t *testing.T) {
+ ps, r, db := setupHaEnv(true)
+ ch := make(chan *redis.Message)
+ msg1 := redis.Message{
+ Channel: "{prefix1},channel",
+ Pattern: "pattern",
+ Payload: "event",
+ }
+ msg2 := redis.Message{
+ Channel: "{prefix2},channel",
+ Pattern: "pattern",
+ Payload: "event",
+ }
+ ps.On("Channel").Return(ch)
+ ps.On("Subscribe").Return(nil)
+ ps.On("Unsubscribe").Return(nil)
+ ps.On("Unsubscribe").Return(nil)
+ ps.On("Close").Return(nil)
+ count := 0
+ receivedChannel1 := ""
+ db.SubscribeChannelDB(func(channel string, payload ...string) {
+ count++
+ receivedChannel1 = channel
+ }, "{prefix1},channel")
+ ch <- &msg1
+ receivedChannel2 := ""
+ db.SubscribeChannelDB(func(channel string, payload ...string) {
+ count++
+ receivedChannel2 = channel
+ }, "{prefix2},channel")
+
+ time.Sleep(1 * time.Second)
+ db.UnsubscribeChannelDB("{prefix1},channel")
+ ch <- &msg2
+ db.UnsubscribeChannelDB("{prefix2},channel")
+ time.Sleep(1 * time.Second)
+ assert.Equal(t, 2, count)
+ assert.Equal(t, "channel", receivedChannel1)
+ assert.Equal(t, "channel", receivedChannel2)
+ r.AssertExpectations(t)
+ ps.AssertExpectations(t)
+}
+