code: @Override
      protected void onPersist(EntityMetadata entityMetadata, Object entity, Object id, List<RelationHolder> rlHolders)
      {
          Object connection = getConnection();
          // Create a hashset and populate data into it
          //
  
          Pipeline pipeLine = null;
          try
          {
              if (isBoundTransaction())
              {
                  pipeLine = ((Jedis) connection).pipelined();
                  onPersist(entityMetadata, entity, id, rlHolders, pipeLine);
              }
              else
              {
                  onPersist(entityMetadata, entity, id, rlHolders, connection);
              }
          }
          finally
          {
              //
              if (pipeLine != null)
              {
                  pipeLine.sync(); // send I/O.. as persist call. so no need to
                                   // read
              } // response?
  
              onCleanup(connection);
          }
  
      }
docs: /*
  (non-Javadoc)
  
  @see
  com.impetus.kundera.client.ClientBase#onPersist(com.impetus.kundera.metadata
  .model.EntityMetadata, java.lang.Object, java.lang.Object,
  java.util.List)