Fix EventHub event source for tests

Change-Id: I8006f84e3ba6ae389b49fba359e696eec352ae46 Signed-off-by: Sandra Vrtikapa <sandra.vrtikapa@securekey.com>
hyperledger · Apr 6, 2017 · ca82dda · ca82dda
1 parent c0d0e22
commit ca82dda
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 8 deletions.
diff --git a/config/config.go b/config/config.go
@@ -158,12 +158,7 @@ func GetPeersConfig() []PeerConfig {
 		if p.Port == "" {
 			panic(fmt.Sprintf("port key not exist or empty for %s", key))
 		}
-		if p.EventHost == "" {
-			panic(fmt.Sprintf("event_host not exist or empty for %s", key))
-		}
-		if p.EventPort == "" {
-			panic(fmt.Sprintf("event_port not exist or empty for %s", key))
-		}
+
 		if IsTLSEnabled() && p.TLSCertificate == "" {
 			panic(fmt.Sprintf("tls.certificate not exist or empty for %s", key))
 		}

diff --git a/test/fixtures/config/config_test.yaml b/test/fixtures/config/config_test.yaml
@@ -13,8 +13,6 @@ client:
   peer2:
     host: "localhost"
     port: 7056
-    event_host: "localhost"
-    event_port: 7058
     tls:
       # Certificate location absolute path
       certificate: "$GOPATH/src/github.com/hyperledger/fabric-sdk-go/test/fixtures/tls/peers/peer1/ca-cert.pem"

diff --git a/test/integration/base_test_setup.go b/test/integration/base_test_setup.go
@@ -160,6 +160,7 @@ func (setup *BaseSetupImpl) GetEventHub() (events.EventHub, error) {
 	foundEventHub := false
 	for _, p := range config.GetPeersConfig() {
 		if p.EventHost != "" && p.EventPort != "" {
+			fmt.Printf("******* EventHub connect to peer (%s:%s) *******\n", p.EventHost, p.EventPort)
 			eventHub.SetPeerAddr(fmt.Sprintf("%s:%s", p.EventHost, p.EventPort), p.TLSCertificate, p.TLSServerHostOverride)
 			foundEventHub = true
 			break