| func main() { | |
| err := shim.Start(new(SampleChaincode)) | |
| if err != nil { | |
| fmt.Println("Could not start SampleChaincode") | |
| } else { | |
| fmt.Println("SampleChaincode successfully started") | |
| } | |
| } |
| func (t *SampleChaincode) Query(stub shim.ChaincodeStubInterface, function string, args []string) ([]byte, error) { | |
| fmt.Println("query is running " + function) | |
| // Handle different functions | |
| if function == "dummy_query" { //read a variable | |
| fmt.Println("hi there " + function) //error |
| func (t *SimpleChaincode) Invoke(stub shim.ChaincodeStubInterface, function string, args []string) ([]byte, error) { | |
| fmt.Println("invoke is running " + function) | |
| // Handle different functions | |
| if function == "init" { | |
| return t.Init(stub, "init", args) | |
| } else if function == "write" { | |
| return t.write(stub, args) | |
| } | |
| fmt.Println("invoke did not find func: " + function) |
| func (t *SampleChaincode) Init(stub shim.ChaincodeStubInterface, function string, args []string) ([]byte, error) { | |
| if len(args) != 1 { | |
| return nil, errors.New("Incorrect number of arguments. Expecting 1") | |
| } | |
| err := stub.PutState("emp_name", []byte(args[0])) |
#Kafka - Messaging Basics This assumes you are starting fresh and have no existing Kafka or ZooKeeper data. See http://kafka.apache.org/documentation.html#quickstart for more details.
##Install Java
sudo apt-get install python-software-properties
sudo add-apt-repository ppa:webupd8team/java
sudo apt-get update
sudo apt-get install oracle-java8-installer