Package org.jredis.protocol

Examples of org.jredis.protocol.BulkResponse

1202
1203
1204
1205
1206
1207
1208
1209
1210
1211
  public static class FutureDouble extends FutureResultBase implements Future<Double>{

        protected FutureDouble (Future<Response> pendingRequest) { super(pendingRequest); }

        public Double get () throws InterruptedException, ExecutionException {
          BulkResponse bulkResp = (BulkResponse) pendingRequest.get();
          if(bulkResp.getBulkData() != null)
            return Convert.toDouble(bulkResp.getBulkData());
          return null;
        }
View Full Code Here
1211
1212
1213
1214
1215
1216
1217
1218
1219
1220
        }

        public Double get (long timeout, TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException
        {
          BulkResponse bulkResp = (BulkResponse) pendingRequest.get(timeout, unit);
          if(bulkResp.getBulkData() != null)
            return Convert.toDouble(bulkResp.getBulkData());
          return null;
        }
View Full Code Here
1222
1223
1224
1225
1226
1227
1228
1229
  public static class FutureByteArray extends FutureResultBase implements Future<byte[]>{

        protected FutureByteArray (Future<Response> pendingRequest) { super(pendingRequest); }

        public byte[] get () throws InterruptedException, ExecutionException {
          BulkResponse resp = (BulkResponse) pendingRequest.get();
          return resp.getBulkData();
        }
View Full Code Here
1229
1230
1231
1232
1233
1234
1235
1236
        }

        public byte[] get (long timeout, TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException
        {
          BulkResponse resp = (BulkResponse) pendingRequest.get(timeout, unit);
          return resp.getBulkData();
        }
View Full Code Here
1262
1263
1264
1265
1266
1267
1268
1269
          list.add(tokenizer.nextToken());
        }
        return list;
        }
        public List<String> get () throws InterruptedException, ExecutionException {
          BulkResponse resp = (BulkResponse) pendingRequest.get();
          return getResultList(resp);
        }
View Full Code Here
1269
1270
1271
1272
1273
1274
1275
1276
        }

        public List<String> get (long timeout, TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException
        {
          BulkResponse resp = (BulkResponse) pendingRequest.get(timeout, unit);
          return getResultList(resp);
        }
View Full Code Here
1290
1291
1292
1293
1294
1295
1296
1297
          infomap.put(key, value);
        }
        return infomap;
        }
        public Map<String, String> get () throws InterruptedException, ExecutionException {
          BulkResponse resp = (BulkResponse) pendingRequest.get();
          return getResultMap(resp);
        }
View Full Code Here
1297
1298
1299
1300
1301
1302
1303
1304
        }

        public Map<String, String> get (long timeout, TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException
        {
          BulkResponse resp = (BulkResponse) pendingRequest.get(timeout, unit);
          return getResultMap(resp);
        }
View Full Code Here
1604
1605
1606
1607
1608
1609
1610
1611
1612
1613
        protected FutureDouble (Future<Response> pendingRequest) { super(pendingRequest); }

        @SuppressWarnings("boxing")
    public Double get () throws InterruptedException, ExecutionException {
          BulkResponse bulkResp = (BulkResponse) pendingRequest.get();
          if(bulkResp.getBulkData() != null)
            return Convert.toDouble(bulkResp.getBulkData());
          return null;
        }
View Full Code Here
1614
1615
1616
1617
1618
1619
1620
1621
1622
1623
        @SuppressWarnings("boxing")
    public Double get (long timeout, TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException
        {
          BulkResponse bulkResp = (BulkResponse) pendingRequest.get(timeout, unit);
          if(bulkResp.getBulkData() != null)
            return Convert.toDouble(bulkResp.getBulkData());
          return null;
        }
View Full Code Here
TOP

Related Classes of org.jredis.protocol.BulkResponse

  • org.jredis.ri.alphazero.JRedisFutureSupport$FutureByteArray
  • org.jredis.ri.alphazero.JRedisFutureSupport$FutureDouble
  • org.jredis.ri.alphazero.JRedisFutureSupport$FutureInfo
  • org.jredis.ri.alphazero.JRedisFutureSupport$FutureKeyList
  • org.jredis.ri.alphazero.JRedisSupport
  • org.springframework.data.redis.connection.jredis.JRedisConnectionIntegrationTests
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.