FAB-3529 remove unused variables and functions

remove unused variables and functions found by unused

Change-Id: I5e981ead1aad7451e6b26186e764cd8fb18c2cb9
Signed-off-by: Christopher Ferris <[email protected]>

Author: christo4ferris

events/consumer/consumer.go

@@ -93,7 +93,7 @@ func (ec *EventsClient) RegisterAsync(ies []*ehpb.Interest) error {
 	emsg := &ehpb.Event{Event: &ehpb.Event_Register{Register: &ehpb.Register{Events: ies}}}
 	var err error
 	if err = ec.send(emsg); err != nil {
-		fmt.Printf("error on Register send %s\n", err)
+		consumerLogger.Errorf("error on Register send %s\n", err)
 	}
 	return err
 }
@@ -140,37 +140,6 @@ func (ec *EventsClient) UnregisterAsync(ies []*ehpb.Interest) error {
 	return err
 }
 
-// unregister - unregisters interest in a event
-func (ec *EventsClient) unregister(ies []*ehpb.Interest) error {
-	var err error
-	if err = ec.UnregisterAsync(ies); err != nil {
-		return err
-	}
-
-	regChan := make(chan struct{})
-	go func() {
-		defer close(regChan)
-		in, inerr := ec.stream.Recv()
-		if inerr != nil {
-			err = inerr
-			return
-		}
-		switch in.Event.(type) {
-		case *ehpb.Event_Unregister:
-		case nil:
-			err = fmt.Errorf("invalid nil object for unregister")
-		default:
-			err = fmt.Errorf("invalid unregistration object")
-		}
-	}()
-	select {
-	case <-regChan:
-	case <-time.After(ec.regTimeout):
-		err = fmt.Errorf("timeout waiting for unregistration")
-	}
-	return err
-}
-
 // Recv recieves next event - use when client has not called Start
 func (ec *EventsClient) Recv() (*ehpb.Event, error) {
 	in, err := ec.stream.Recv()

events/events_test.go

@@ -149,11 +149,6 @@ func createTestChaincodeEvent(tid string, typ string) *ehpb.Event {
 	return emsg
 }
 
-func closeListenerAndSleep(l net.Listener) {
-	l.Close()
-	time.Sleep(2 * time.Second)
-}
-
 // Test the invocation of a transaction.
 func TestReceiveMessage(t *testing.T) {
 	var err error

events/producer/producer.go

@@ -19,14 +19,11 @@ package producer
 import (
 	"fmt"
 	"io"
-	"time"
 
 	"github.com/hyperledger/fabric/common/flogging"
 	pb "github.com/hyperledger/fabric/protos/peer"
 )
 
-const defaultTimeout = time.Second * 3
-
 var logger = flogging.MustGetLogger("eventhub_producer")
 
 // EventsServer implementation of the Peer service