jedis - Pipeline では Jedis を使用できません。パイプラインを使用するか、jedis の状態をリセットしてください

Question

Spring Data Redis でパイプライン コマンドを実行できません。StringRedisTemplate を使用しています。spring-data-redis 1.6.1、spring boot 1.3.2、および jedis 2.7.3 と 2.8.0 の両方。

コード：

public void saveUserActivityEvents(Event... events) {   
    List<Object> results = stringRedisTemplate.executePipelined(
              new RedisCallback<Object>() {
                public Object doInRedis(RedisConnection connection) throws DataAccessException {
                  StringRedisConnection stringRedisConn = (StringRedisConnection)connection;
                  for(int i=0; i< events.length; i++) {
                    Event event = events[i];
                    String userId = getUserId(event.getUser());       
                    String eventType = event.getEventType();
                    String itemId = event.getItem();
                    Integer amount = event.getAmount() == null ? 0 : Integer.parseInt(event.getAmount());
                    Double timestamp = Double.valueOf(event.getTimestamp());
                    Map<String, String> valueMap= new HashMap<String, String>();            
                    valueMap.put("itemId", itemId);
                    valueMap.put("userId", userId);
                    String userItemEventsKey = StrSubstitutor.replace(Constants.KEY_USER_ITEM_EVENTS, valueMap);
                    valueMap.put("userId", userId);     
                    String userItemsKey = StrSubstitutor.replace(Constants.KEY_USER_ITEMS, valueMap);
                    stringRedisConn.zAdd(userItemsKey, timestamp, itemId);
                    stringRedisConn.hIncrBy(userItemEventsKey, eventType, amount);                      
                    long expireInMs = TimeoutUtils.toMillis(getExpiryTimeInDays(event.getUser()), TimeUnit.DAYS);
                    stringRedisConn.pExpire(userItemEventsKey, expireInMs);
                  }
                return null;
              }
            });



}

pExpireを実行すると件名に例外で吹きます。リファレンス ガイドで提案されている別のフレーバーを試してみました。

execute(redisCallback, true, true)

同じ結果です。何か案が？ありがとう